adapter

Documentation

Index

• type Adapter
• 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 DummyAdapter
  • func NewDummyAdapter() *DummyAdapter
  • func (s *DummyAdapter) Name() string
  • func (s *DummyAdapter) Notify(id string, e events.Log) error
  • func (s *DummyAdapter) Stop(id string) error
• 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 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 DummyAdapter

type DummyAdapter struct {
	Bucket string
}

func NewDummyAdapter

func NewDummyAdapter() *DummyAdapter

NewS3Subscriber creates new DummySubscriber which will send data to local MinIO bucket

func (*DummyAdapter) Name

func (s *DummyAdapter) Name() string

func (*DummyAdapter) Notify

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

func (*DummyAdapter) Stop

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

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