plugins

type CheckMessageSidelineImpl interface {
	CheckMessageSideline(key []byte) ([]byte, error)
	SidelineMessage(msg []byte) SidelineMessageResponse
	InitialisePlugin(conf []byte) error
}

type CheckMessageSidelineImplPlugin struct{}

type CheckMessageSidelineRPC struct {
	Client *rpc.Client
}

type CheckMessageSidelineRPCServer struct {
	// This is the real implementation
	Impl CheckMessageSidelineImpl
}

type CheckMessageSidelineResponse struct {
	SidelineMessage bool
	Version         int32
}

type KafkaHttpSidelineMeta struct {
	Endpoint string
	Headers  map[string]string
}

type Manager struct {
	Type    string                 // id for types of plugins this manager deals with
	Glob    string                 // glob match for plugin filenames
	Path    string                 // path for plugins
	Plugins map[string]*PluginInfo // Info for foudn plugins
	// contains filtered or unexported fields
}

type PluginInfo struct {
	ID     string
	Path   string
	Client *plugin.Client
}

type ScanImpl interface {
	ScanWithStartRowEndRow(request ScanWithStartRowEndRowRequest) ([]string, error)
	ScanWithStartTimeEndTime(request ScanWithStartTimeEndTimeRequest) ([]string, error)
}

type ScanImplPlugin struct{}

type ScanImplRPC struct {
	Client *rpc.Client
}

type ScanImplRPCServer struct {
	Impl ScanImpl
}

type ScanWithStartRowEndRowRequest struct {
	StartKey string
	EndKey   string
}

type ScanWithStartTimeEndTimeRequest struct {
	StartTime int64
	EndTime   int64
	StartKey  string
	EndKey    string
}

type SidelineMessage struct {
	GroupId           string
	Partition         int32
	EntityId          string
	Offset            int64
	ConsumerGroupName string
	ClusterName       string
	Message           []byte
	Version           int32
	ConnectionType    string
	SidelineMeta      []byte
}

type SidelineMessageResponse struct {
	Success                     bool
	ConcurrentModificationError bool
	UnknownError                bool
	ErrorMessage                string
}

type UnsidelineByKeyRequest struct {
	Key      string
	DmuxItem string
}

type UnsidelineImpl interface {
	UnsidelineByKey(request UnsidelineByKeyRequest) (string, error)
}

type UnsidelineImplPlugin struct{}

type UnsidelineImplRPC struct {
	Client *rpc.Client
}

type UnsidelineImplRPCServer struct {
	Impl UnsidelineImpl
}