plugin

type PipelineContextData struct {
	ID          string
	ContentType string
	Data        []byte
	Metadata    map[string]interface{}
}

type PipelinePlugin struct {
	Impl PipelineProcessor
}

type PipelineProcessor interface {
	Name() (string, error)

	GetCapabilities() (PipelineProcessorCapability, error)

	Configure(cfg map[string]interface{}) error

	Process(data *PipelineContextData) (*PipelineContextData, error)

	Health() error
}

type PipelineProcessorCapability struct {
	Types []PipelineProcessorCapabilityType `json:"types"`
}

type PipelineProcessorCapabilityType int32

type RpcClient struct {
	Client *rpc.Client
}

type RpcServer struct {
	Impl PipelineProcessor
}

type ServeRegistrationErrorResponse struct {
	Error string `json:"error"`
}

type ServeRegistrationServer struct {
	Listener          net.Listener
	Server            *rpc.Server
	WaitGroup         sync.WaitGroup
	ActiveConnections sync.Map
	Cancel            context.CancelFunc
}