Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CloudwatchState ¶
type CloudwatchState struct {
LogGroupName string
LogStream *LogStream
CloudwatchLogsSvc *cloudwatchlogs.CloudWatchLogs
MaxBufferSize int
BufferTimeLimit int
MaxBufferEntries int
}
func (*CloudwatchState) Flush ¶
func (c *CloudwatchState) Flush()
func (*CloudwatchState) GetName ¶
func (c *CloudwatchState) GetName() string
func (*CloudwatchState) Initialize ¶
func (c *CloudwatchState) Initialize()
func (*CloudwatchState) Store ¶
func (c *CloudwatchState) Store(flow *flowstore.Flow)
type LogStream ¶
type LogStream struct {
LogStreamName string
LogGroupName string
LastSequenceToken *string
// contains filtered or unexported fields
}
func (*LogStream) IngestEvent ¶
func (*LogStream) UploadBufferedEvents ¶
func (l *LogStream) UploadBufferedEvents()
type S3State ¶
type S3State struct {
S3Client *s3.Client
ActiveObject *s3Object
BucketName string
MaxObjectSize int
}
func (*S3State) Initialize ¶
func (s *S3State) Initialize()
type StorageBackend ¶
type StorageManager ¶
type StorageManager struct {
InputChannel chan *flowstore.Flow
StopChannel chan bool
StorageBackends []StorageBackend
Stopped chan bool
}
func NewStorageManager ¶
func NewStorageManager(input chan *flowstore.Flow, backends []StorageBackend) StorageManager
func (*StorageManager) Start ¶
func (sm *StorageManager) Start()
func (*StorageManager) Stop ¶
func (sm *StorageManager) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.