Documentation
¶
Index ¶
- type CollectResponse
- type Observer
- type PluginDescribeResponse
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CollectResponse ¶
type CollectResponse struct {
ExecutionId string
Schema *schema.RowSchema
FromTime *row_source.ResolvedFromTime
}
func CollectResponseFromProto ¶
func CollectResponseFromProto(resp *proto.CollectResponse) *CollectResponse
type PluginDescribeResponse ¶
type PluginDescribeResponse struct {
Name string `json:"name"`
TableSchemas schema.SchemaMap `json:"tables"`
Sources row_source.SourceMetadataMap `json:"sources"`
}
func DescribeResponseFromProto ¶
func DescribeResponseFromProto(resp *proto.DescribeResponse) *PluginDescribeResponse
type PluginManager ¶
type PluginManager struct {
// map of running plugins, keyed by plugin name
Plugins map[string]*grpc.PluginClient
// contains filtered or unexported fields
}
func New ¶
func New() *PluginManager
func (*PluginManager) AddObserver ¶
func (p *PluginManager) AddObserver(o Observer)
AddObserver adds a n observer to the plugin manager
func (*PluginManager) Close ¶
func (p *PluginManager) Close()
func (*PluginManager) Collect ¶
func (p *PluginManager) Collect(ctx context.Context, partition *config.Partition, fromTime time.Time, collectionTempDir string) (*CollectResponse, error)
Collect starts the plugin if needed, discovers the artifacts and download them for the given partition.
func (*PluginManager) Describe ¶
func (p *PluginManager) Describe(ctx context.Context, pluginName string) (*PluginDescribeResponse, error)
Describe starts the plugin if needed, discovers the artifacts and download them for the given partition.
Source Files
Click to show internal directories.
Click to hide internal directories.