plugin_manager

Jan 30, 2025

Changes in this version

+ type CollectResponse struct

+ ExecutionId string

+ FromTime *row_source.ResolvedFromTime

+ Schema *schema.RowSchema

+ func CollectResponseFromProto(resp *proto.CollectResponse) *CollectResponse

+ type Observer interface

+ Notify func(event *proto.Event)

+ type PluginDescribeResponse struct

+ Name string

+ Sources row_source.SourceMetadataMap

+ TableSchemas schema.SchemaMap

+ func DescribeResponseFromProto(resp *proto.DescribeResponse) *PluginDescribeResponse

+ type PluginManager struct

+ Plugins map[string]*grpc.PluginClient

+ func New() *PluginManager

+ func (p *PluginManager) AddObserver(o Observer)

+ func (p *PluginManager) Close()

+ func (p *PluginManager) Collect(ctx context.Context, partition *config.Partition, fromTime time.Time, ...) (*CollectResponse, error)

+ func (p *PluginManager) Describe(ctx context.Context, pluginName string) (*PluginDescribeResponse, error)

+ func (p *PluginManager) UpdateCollectionState(ctx context.Context, partition *config.Partition, fromTime time.Time, ...) error