Hüseyin BABAL huseyinbabal

## kubectl_krew_node.md

      
              1 file
            
          
              1 fork
            
          
              0 comments
            
          
              1 star
            
          
                huseyinbabal
                / kubectl_krew_node.md
            
            
              Created
              September 27, 2023 11:29
            
              
                kubectl, krew, nodejs docker image
              
          
    Dockerfile

# Use the official Docker image as a parent image
FROM docker:latest

# Install dependencies
RUN apk add --no-cache \
    curl \
    git \
 bash \


## stream_pod_logs.go
func streamLogs(clientset kubernetes.Interface, namespace, labelSelector string) error {
	ctx := context.TODO()

	// Watch for changes to pods that match the label selector
	listWatcher := cache.NewListWatchFromClient(
		clientset.CoreV1().RESTClient(),
		"pods",
		namespace,
		fields.Everything(),
		labels.SelectorFromSet(labels.Set(labelSelector)),

## keptn_plugin_comm_config.yaml
...
 slack:
    enabled: true
    token: "xoxb-..."
    channels:
      'default':
        name: botkube-demo
        bindings:
          sources:
            - keptn

## keptn_plugin_source_configuration.yaml
'keptn':
  ## Keptn source configuration
  ## Plugin name syntax: <repo>/<plugin>[@<version>]. If version is not provided, the latest version from repository is used.
  botkube/keptn:
    # -- If true, enables `keptn` source.
    enabled: true
    config:
      project: "botkube"
      url: "http://localhost:8080/api"
      token: "keptn_token"

## botkube_repo_config.yaml
// config.yaml
...
plugins:
  repositories:
    botkube:
      url: http://localhost:8080/plugins-dev-index.yaml
...

## plugin_serve.sh
npx serve --listen 8080

## botkube_plugin_index_generate.sh
PLUGIN_DOWNLOAD_URL_BASE_PATH=http://localhost:8080/plugin-dist make gen-plugins-index

## keptn_consume_events.go
// source.go
package keptn
const pollPeriodInSeconds = 5
...
func (p *Source) consumeEvents(ctx context.Context, cfg Config, ch chan<- source.Event) {
	keptn, err := NewClient(cfg.URL, cfg.Token)
	log := loggerx.New(cfg.Log)
	exitOnError(err, log)
	for {
		req := GetEventsRequest{

## keptn_plugin_core_contract.go
// source.go
Stream(ctx context.Context, input source.StreamInput) (source.StreamOutput, error)
Metadata(_ context.Context) (api.MetadataOutput, error)

## keptn_client_implementation.go
// client.go
package keptn
import (
	api "github.com/keptn/go-utils/pkg/api/utils/v2"
	"time"
)
// Client Keptn client
type Client struct {
	// API refers to Keptn client. https://github.com/keptn/go-utils
	API *api.APISet
	func streamLogs(clientset kubernetes.Interface, namespace, labelSelector string) error {
	ctx := context.TODO()

	// Watch for changes to pods that match the label selector
	listWatcher := cache.NewListWatchFromClient(
	clientset.CoreV1().RESTClient(),
	"pods",
	namespace,
	fields.Everything(),
	labels.SelectorFromSet(labels.Set(labelSelector)),
	...
	slack:
	enabled: true
	token: "xoxb-..."
	channels:
	'default':
	name: botkube-demo
	bindings:
	sources:
	- keptn
	'keptn':
	## Keptn source configuration
	## Plugin name syntax: <repo>/<plugin>[@<version>]. If version is not provided, the latest version from repository is used.
	botkube/keptn:
	# -- If true, enables `keptn` source.
	enabled: true
	config:
	project: "botkube"
	url: "http://localhost:8080/api"
	token: "keptn_token"
	// config.yaml
	...
	plugins:
	repositories:
	botkube:
	url: http://localhost:8080/plugins-dev-index.yaml
	...
	// source.go
	package keptn
	const pollPeriodInSeconds = 5
	...
	func (p *Source) consumeEvents(ctx context.Context, cfg Config, ch chan<- source.Event) {
	keptn, err := NewClient(cfg.URL, cfg.Token)
	log := loggerx.New(cfg.Log)
	exitOnError(err, log)
	for {
	req := GetEventsRequest{
	// source.go
	Stream(ctx context.Context, input source.StreamInput) (source.StreamOutput, error)
	Metadata(_ context.Context) (api.MetadataOutput, error)
	// client.go
	package keptn
	import (
	api "github.com/keptn/go-utils/pkg/api/utils/v2"
	"time"
	)
	// Client Keptn client
	type Client struct {
	// API refers to Keptn client. https://github.com/keptn/go-utils
	API *api.APISet