adapter

Documentation

Index

• type Adapter
• type BufferInfo
• type CloudAdapter
  • func NewCloudConsumer() *CloudAdapter
  • func (s *CloudAdapter) Name() string
  • func (s *CloudAdapter) Notify(id string, e events.Log) error
  • func (s *CloudAdapter) Stop(id string) error
• type DebugAdapter
  • func NewDebugAdapter() *DebugAdapter
  • func (s *DebugAdapter) Name() string
  • func (s *DebugAdapter) Notify(id string, e events.Log) error
  • func (s *DebugAdapter) Stop(id string) error
• type ErrChucnkTooBig
  • func (e ErrChucnkTooBig) Error() string
• type ErrIdNotFound
  • func (e ErrIdNotFound) Error() string
• type ErrMinioConsumerDisconnected
  • func (e ErrMinioConsumerDisconnected) 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) Name() string
  • func (s *MinioAdapter) Notify(id string, e events.Log) error
  • func (s *MinioAdapter) Stop(id string) error
  • func (s *MinioAdapter) UpdateBuffInfo(id string, buffInfo BufferInfo)
• type S3Adapter
  • func NewS3Adapter() *S3Adapter
  • func (s *S3Adapter) Name() string
  • func (s *S3Adapter) Notify(id string, e events.Log) error
  • func (s *S3Adapter) Stop(id string) error

Types

type Adapter

type Adapter interface {
	// Notify will send data log events for particaular execution id
	Notify(id string, event events.Log) error
	// Stop will stop listening subscriber from sending data
	Stop(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 {
	Bucket string
}

func NewCloudConsumer

func NewCloudConsumer() *CloudAdapter

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

func (*CloudAdapter) Name

func (s *CloudAdapter) Name() string

func (*CloudAdapter) Notify

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

func (*CloudAdapter) Stop

func (s *CloudAdapter) Stop(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) Name

func (s *DebugAdapter) Name() string

func (*DebugAdapter) Notify

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

func (*DebugAdapter) Stop

func (s *DebugAdapter) Stop(id string) error

type ErrChucnkTooBig

type ErrChucnkTooBig struct {
	Length int
}

func (ErrChucnkTooBig) Error

func (e ErrChucnkTooBig) Error() string

type ErrIdNotFound

type ErrIdNotFound struct {
	Id string
}

func (ErrIdNotFound) Error

func (e ErrIdNotFound) Error() string

type ErrMinioConsumerDisconnected

type ErrMinioConsumerDisconnected struct {
}

func (ErrMinioConsumerDisconnected) Error

func (e ErrMinioConsumerDisconnected) 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)

MinioConsumer creates new MinioSubscriber 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) Name

func (s *MinioAdapter) Name() string

func (*MinioAdapter) Notify

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

func (*MinioAdapter) Stop

func (s *MinioAdapter) Stop(id string) error

func (*MinioAdapter) UpdateBuffInfo

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

type S3Adapter

type S3Adapter struct {
	Bucket string
}

func NewS3Adapter

func NewS3Adapter() *S3Adapter

NewS3Adapter creates new S3Subscriber which will send data to local MinIO bucket

func (*S3Adapter) Name

func (s *S3Adapter) Name() string

func (*S3Adapter) Notify

func (s *S3Adapter) Notify(id string, e events.Log) error

func (*S3Adapter) Stop

func (s *S3Adapter) Stop(id string) error