castai

Documentation

Index

• func IsGRPCError(err error, codes ...codes.Code) bool
• type Client
  • func NewClient(userAgent string, cfg Config) (*Client, error)
  • func (c *Client) Close()
• type Config
  • func (c Config) Valid() bool
• type LogsExporter
  • func NewLogsExporter(client *Client) *LogsExporter
  • func (l *LogsExporter) AddLogEvent(e *castaipb.LogEvent)
  • func (l *LogsExporter) ExportFunc() logging.ExportFunc
  • func (l *LogsExporter) Run(ctx context.Context) error
• type PromMetricsExporter
  • func NewPromMetricsExporter(log *logging.Logger, logsExporter logsExporter, gatherer prometheus.Gatherer, ...) *PromMetricsExporter
  • func (e *PromMetricsExporter) Run(ctx context.Context) error
• type PromMetricsExporterConfig
• type WriteStream
  • func NewWriteStream[T, U any](ctx context.Context, ...) *WriteStream[T, U]
  • func (w *WriteStream[T, U]) Close() error
  • func (w *WriteStream[T, U]) Recv(m T) error
  • func (w *WriteStream[T, U]) Send(m T) error

Functions

func IsGRPCError

func IsGRPCError(err error, codes ...codes.Code) bool

Types

type Client

type Client struct {
	GRPC castaipb.RuntimeSecurityAgentAPIClient
	// contains filtered or unexported fields
}

func NewClient

func NewClient(userAgent string, cfg Config) (*Client, error)

func (*Client) Close

func (c *Client) Close()

type Config

type Config struct {
	ClusterID   string `json:"clusterID"`
	APIKey      string `json:"-"`
	APIGrpcAddr string `json:"APIGrpcAddr"`
	Insecure    bool   `json:"insecure"`
}

func (Config) Valid

func (c Config) Valid() bool

type LogsExporter

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

func NewLogsExporter

func NewLogsExporter(client *Client) *LogsExporter

func (*LogsExporter) AddLogEvent

func (l *LogsExporter) AddLogEvent(e *castaipb.LogEvent)

func (*LogsExporter) ExportFunc

func (l *LogsExporter) ExportFunc() logging.ExportFunc

func (*LogsExporter) Run

func (l *LogsExporter) Run(ctx context.Context) error

type PromMetricsExporter

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

func NewPromMetricsExporter

func NewPromMetricsExporter(log *logging.Logger, logsExporter logsExporter, gatherer prometheus.Gatherer, cfg PromMetricsExporterConfig) *PromMetricsExporter

func (*PromMetricsExporter) Run

func (e *PromMetricsExporter) Run(ctx context.Context) error

type PromMetricsExporterConfig

type PromMetricsExporterConfig struct {
	PodName        string
	MetricsPrefix  string
	ExportInterval time.Duration
}

type WriteStream

type WriteStream[T, U any] struct {
	ReopenDelay time.Duration
	// contains filtered or unexported fields
}

WriteStream wraps grpc client stream and handles stream reopen in case of send errors.

func NewWriteStream

func NewWriteStream[T, U any](ctx context.Context, createStreamFunc func(ctx context.Context) (grpc.ClientStream, error)) *WriteStream[T, U]

func (*WriteStream[T, U]) Close

func (w *WriteStream[T, U]) Close() error

func (*WriteStream[T, U]) Recv

func (w *WriteStream[T, U]) Recv(m T) error

func (*WriteStream[T, U]) Send

func (w *WriteStream[T, U]) Send(m T) error