adapter

Documentation

Index

• type Adapter
• type BufferInfo
• type CloudAdapter
  • func NewCloudAdapter(grpcConn pb.CloudLogsServiceClient, agentApiKey string) *CloudAdapter
  • func (s *CloudAdapter) Init(ctx context.Context, id string) error
  • func (s *CloudAdapter) Name() string
  • func (s *CloudAdapter) Notify(ctx context.Context, id string, e events.Log) error
  • func (s *CloudAdapter) Stop(ctx context.Context, id string) error
• type DebugAdapter
  • func NewDebugAdapter() *DebugAdapter
  • func (s *DebugAdapter) Init(ctx context.Context, id string) error
  • func (s *DebugAdapter) Name() string
  • func (s *DebugAdapter) Notify(ctx context.Context, id string, e events.Log) error
  • func (s *DebugAdapter) Stop(ctx context.Context, id string) error
• type ErrChunckTooBig
  • func (e ErrChunckTooBig) Error() string
• type ErrIdNotFound
  • func (e ErrIdNotFound) Error() string
• type ErrMinioAdapterDisconnected
  • func (e ErrMinioAdapterDisconnected) Error() string
• type MinioAdapter
  • func NewMinioAdapter(endpoint, accessKeyID, secretAccessKey, region, token, bucket string, ...) (*MinioAdapter, error)
  • func (s *MinioAdapter) DeleteBuffInfo(id string)
  • func (s *MinioAdapter) GetBuffInfo(id string) (BufferInfo, bool)
  • func (s *MinioAdapter) Init(ctx context.Context, id string) error
  • func (s *MinioAdapter) Name() string
  • func (s *MinioAdapter) Notify(ctx context.Context, id string, e events.Log) error
  • func (s *MinioAdapter) Stop(ctx context.Context, id string) error
  • func (s *MinioAdapter) UpdateBuffInfo(id string, buffInfo BufferInfo)

Types

type Adapter

type Adapter interface {
	// Init will init for given id
	Init(ctx context.Context, id string) error
	// Notify will send data log events for particaular execution id
	Notify(ctx context.Context, id string, event events.Log) error
	// Stop will stop listening subscriber from sending data
	Stop(ctx context.Context, id string) error
	// Name subscriber name
	Name() string
}

Adapter will listen to log chunks, and handle them based on log id (execution Id)

type BufferInfo

type BufferInfo struct {
	Buffer *bytes.Buffer
	Part   int
}

type CloudAdapter

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

func NewCloudAdapter

func NewCloudAdapter(grpcConn pb.CloudLogsServiceClient, agentApiKey string) *CloudAdapter

NewCloudConsumer creates new CloudSubscriber which will send data to local MinIO bucket

func (*CloudAdapter) Init

func (s *CloudAdapter) Init(ctx context.Context, id string) error

func (*CloudAdapter) Name

func (s *CloudAdapter) Name() string

func (*CloudAdapter) Notify

func (s *CloudAdapter) Notify(ctx context.Context, id string, e events.Log) error

func (*CloudAdapter) Stop

func (s *CloudAdapter) Stop(ctx context.Context, id string) error

type DebugAdapter

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

func NewDebugAdapter

func NewDebugAdapter() *DebugAdapter

NewDebugAdapter creates new DebugAdapter which will write logs to stdout

func (*DebugAdapter) Init

func (s *DebugAdapter) Init(ctx context.Context, id string) error

func (*DebugAdapter) Name

func (s *DebugAdapter) Name() string

func (*DebugAdapter) Notify

func (s *DebugAdapter) Notify(ctx context.Context, id string, e events.Log) error

func (*DebugAdapter) Stop

func (s *DebugAdapter) Stop(ctx context.Context, id string) error

type ErrChunckTooBig

type ErrChunckTooBig struct {
	Length int
}

func (ErrChunckTooBig) Error

func (e ErrChunckTooBig) Error() string

type ErrIdNotFound

type ErrIdNotFound struct {
	Id string
}

func (ErrIdNotFound) Error

func (e ErrIdNotFound) Error() string

type ErrMinioAdapterDisconnected

type ErrMinioAdapterDisconnected struct {
}

func (ErrMinioAdapterDisconnected) Error

func (e ErrMinioAdapterDisconnected) Error() string

type MinioAdapter

type MinioAdapter struct {
	Log *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewMinioAdapter

func NewMinioAdapter(endpoint, accessKeyID, secretAccessKey, region, token, bucket string, ssl, skipVerify bool, certFile, keyFile, caFile string) (*MinioAdapter, error)

NewMinioAdapter creates new MinioAdapter which will send data to local MinIO bucket

func (*MinioAdapter) DeleteBuffInfo

func (s *MinioAdapter) DeleteBuffInfo(id string)

func (*MinioAdapter) GetBuffInfo

func (s *MinioAdapter) GetBuffInfo(id string) (BufferInfo, bool)

func (*MinioAdapter) Init

func (s *MinioAdapter) Init(ctx context.Context, id string) error

func (*MinioAdapter) Name

func (s *MinioAdapter) Name() string

func (*MinioAdapter) Notify

func (s *MinioAdapter) Notify(ctx context.Context, id string, e events.Log) error

func (*MinioAdapter) Stop

func (s *MinioAdapter) Stop(ctx context.Context, id string) error

func (*MinioAdapter) UpdateBuffInfo

func (s *MinioAdapter) UpdateBuffInfo(id string, buffInfo BufferInfo)