cpluginv1

Documentation

Index

• type Data
• type DestinationConfigureRequest
• type DestinationConfigureResponse
• type DestinationPlugin
• type DestinationRunRequest
• type DestinationRunResponse
• type DestinationRunStream
• type DestinationStartRequest
• type DestinationStartResponse
• type DestinationStopRequest
• type DestinationStopResponse
• type DestinationTeardownRequest
• type DestinationTeardownResponse
• type RawData
• type Record
• type SourceConfigureRequest
• type SourceConfigureResponse
• type SourcePlugin
• type SourceRunRequest
• type SourceRunResponse
• type SourceRunStream
• type SourceStartRequest
• type SourceStartResponse
• type SourceStopRequest
• type SourceStopResponse
• type SourceTeardownRequest
• type SourceTeardownResponse
• type SpecifierParameter
• type SpecifierPlugin
• type SpecifierSpecifyRequest
• type SpecifierSpecifyResponse
• type StructuredData

Types

type Data

type Data interface {
	// contains filtered or unexported methods
}

type DestinationConfigureRequest

type DestinationConfigureRequest struct {
	Config map[string]string
}

type DestinationConfigureResponse

type DestinationConfigureResponse struct{}

type DestinationPlugin

type DestinationPlugin interface {
	Configure(context.Context, DestinationConfigureRequest) (DestinationConfigureResponse, error)
	Start(context.Context, DestinationStartRequest) (DestinationStartResponse, error)
	Run(context.Context, DestinationRunStream) error
	Stop(context.Context, DestinationStopRequest) (DestinationStopResponse, error)
	Teardown(context.Context, DestinationTeardownRequest) (DestinationTeardownResponse, error)
}

type DestinationRunRequest

type DestinationRunRequest struct {
	Record Record
}

type DestinationRunResponse

type DestinationRunResponse struct {
	AckPosition []byte
	Error       string
}

type DestinationRunStream

type DestinationRunStream interface {
	Send(DestinationRunResponse) error
	Recv() (DestinationRunRequest, error)
}

type DestinationStartRequest

type DestinationStartRequest struct{}

type DestinationStartResponse

type DestinationStartResponse struct{}

type DestinationStopRequest

type DestinationStopRequest struct{}

type DestinationStopResponse

type DestinationStopResponse struct{}

type DestinationTeardownRequest

type DestinationTeardownRequest struct{}

type DestinationTeardownResponse

type DestinationTeardownResponse struct{}

type RawData

type RawData []byte

type Record

type Record struct {
	Position  []byte
	Metadata  map[string]string
	CreatedAt time.Time
	Key       Data
	Payload   Data
}

type SourceConfigureRequest

type SourceConfigureRequest struct {
	Config map[string]string
}

type SourceConfigureResponse

type SourceConfigureResponse struct{}

type SourcePlugin

type SourcePlugin interface {
	Configure(context.Context, SourceConfigureRequest) (SourceConfigureResponse, error)
	Start(context.Context, SourceStartRequest) (SourceStartResponse, error)
	Run(context.Context, SourceRunStream) error
	Stop(context.Context, SourceStopRequest) (SourceStopResponse, error)
	Teardown(context.Context, SourceTeardownRequest) (SourceTeardownResponse, error)
}

type SourceRunRequest

type SourceRunRequest struct {
	AckPosition []byte
}

type SourceRunResponse

type SourceRunResponse struct {
	Record Record
}

type SourceRunStream

type SourceRunStream interface {
	Send(SourceRunResponse) error
	Recv() (SourceRunRequest, error)
}

type SourceStartRequest

type SourceStartRequest struct {
	Position []byte
}

type SourceStartResponse

type SourceStartResponse struct{}

type SourceStopRequest

type SourceStopRequest struct{}

type SourceStopResponse

type SourceStopResponse struct{}

type SourceTeardownRequest

type SourceTeardownRequest struct{}

type SourceTeardownResponse

type SourceTeardownResponse struct{}

type SpecifierParameter

type SpecifierParameter struct {
	Default     string
	Required    bool
	Description string
}

type SpecifierPlugin

type SpecifierPlugin interface {
	Specify(context.Context, SpecifierSpecifyRequest) (SpecifierSpecifyResponse, error)
}

type SpecifierSpecifyRequest

type SpecifierSpecifyRequest struct{}

type SpecifierSpecifyResponse

type SpecifierSpecifyResponse struct {
	Name              string
	Summary           string
	Description       string
	Version           string
	Author            string
	DestinationParams map[string]SpecifierParameter
	SourceParams      map[string]SpecifierParameter
}

type StructuredData

type StructuredData map[string]interface{}