Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) 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) Stop ¶
func (s *DummyAdapter) Stop(id string) error
Source Files
Click to show internal directories.
Click to hide internal directories.