kubernetes

Documentation

Index

• Variables
• type Client
  • func NewClient(kubeConfigPath string, moduloCrashReportNotif float64, e Exporter) (*Client, error)
  • func (c *Client) HandleNewDaemonSets(ctx context.Context) error
  • func (c *Client) HandleNewDeployments(ctx context.Context) error
  • func (c *Client) HandleNewStatefulSets(ctx context.Context) error
  • func (c *Client) HandlePodErrors(ctx context.Context) error
• type ContainerLog
• type Exporter
• type ReleaseManagerExporter
  • func (e *ReleaseManagerExporter) SendPodErrorEvent(ctx context.Context, event httpinternal.PodErrorEvent) error
  • func (e *ReleaseManagerExporter) SendSuccessfulReleaseEvent(ctx context.Context, event httpinternal.ReleaseEvent) error

Variables

var (
	ErrWatcherClosed = errors.New("channel closed")
)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(kubeConfigPath string, moduloCrashReportNotif float64, e Exporter) (*Client, error)

func (*Client) HandleNewDaemonSets

func (c *Client) HandleNewDaemonSets(ctx context.Context) error

func (*Client) HandleNewDeployments

func (c *Client) HandleNewDeployments(ctx context.Context) error

func (*Client) HandleNewStatefulSets

func (c *Client) HandleNewStatefulSets(ctx context.Context) error

func (*Client) HandlePodErrors

func (c *Client) HandlePodErrors(ctx context.Context) error

type ContainerLog

type ContainerLog struct {
	Level   string
	Message string
}

type Exporter

type Exporter interface {
	// Send a message through the exporter.
	SendSuccessfulReleaseEvent(c context.Context, event httpinternal.ReleaseEvent) error
	SendPodErrorEvent(c context.Context, event httpinternal.PodErrorEvent) error
}

Exporter sends a formatted event to an upstream.

type ReleaseManagerExporter

type ReleaseManagerExporter struct {
	Log         *log.Logger
	Environment string
	Client      httpinternal.Client
}

func (*ReleaseManagerExporter) SendPodErrorEvent

func (e *ReleaseManagerExporter) SendPodErrorEvent(ctx context.Context, event httpinternal.PodErrorEvent) error

func (*ReleaseManagerExporter) SendSuccessfulReleaseEvent

func (e *ReleaseManagerExporter) SendSuccessfulReleaseEvent(ctx context.Context, event httpinternal.ReleaseEvent) error