collector

package

v0.1.3 Latest Latest Go to latest Published: Mar 17, 2025 License: AGPL-3.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

func NewExecutionError(err error, executionId string) error

type AwaitingCompactionMsg struct{}

type CollectionFinishedMsg struct{}

type Collector struct {
	Events chan *proto.Event
	// contains filtered or unexported fields
}

func New(pluginManager *plugin_manager.PluginManager, partition *config.Partition, cancel context.CancelFunc) (*Collector, error)

func (c *Collector) Close()

func (c *Collector) Collect(ctx context.Context, fromTime time.Time) error

func (c *Collector) Compact(ctx context.Context) error

func (c *Collector) Errors() []string

func (c *Collector) Notify(event *proto.Event)

Notify implements observer.Observer send an event down the channel to be picked up by the handlePluginEvent goroutine

func (c *Collector) StatusString() string

func (c *Collector) WaitForCompletion(ctx context.Context) error

WaitForCompletion waits for our execution to have state ExecutionState_COMPLETE

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

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

func (e ExecutionError) Error() string

func (e *ExecutionError) Unwrap() error

Unwrap implements error wrapping.

type ExecutionState int

enum of execution states

const (
	ExecutionState_PENDING ExecutionState = iota
	ExecutionState_STARTED ExecutionState = iota
	ExecutionState_COMPLETE
	ExecutionState_ERROR
)