source

type Config struct {

	// RawYAML contains the Source configuration in YAML definitions.
	RawYAML []byte `protobuf:"bytes,1,opt,name=rawYAML,proto3" json:"rawYAML,omitempty"`
	// contains filtered or unexported fields
}

type Dependency struct {

	// urls is the map of URL of the dependency. The key is in format of "os/arch", such as "linux/amd64".
	Urls map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Event struct {
	Message         api.Message
	RawObject       any
	AnalyticsLabels map[string]interface{}
}

type JSONSchema struct {

	// value is the string value of the JSON schema.
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// ref_url is the remote reference of the JSON schema.
	RefUrl string `protobuf:"bytes,2,opt,name=ref_url,json=refUrl,proto3" json:"ref_url,omitempty"`
	// contains filtered or unexported fields
}

type MetadataResponse struct {

	// version is a version of a given plugin. It should follow the SemVer syntax.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// description is a description of a given plugin.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// json_schema is a JSON schema of a given plugin.
	JsonSchema *JSONSchema `protobuf:"bytes,3,opt,name=json_schema,json=jsonSchema,proto3" json:"json_schema,omitempty"`
	// dependencies is a list of dependencies of a given plugin.
	Dependencies map[string]*Dependency `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Plugin struct {
	// The GRPC plugin must still implement the Plugin interface.
	plugin.NetRPCUnsupportedPlugin

	// Source represent a concrete implementation that handles the business logic.
	Source Source
}

type Source interface {
	Stream(context.Context, StreamInput) (StreamOutput, error)
	Metadata(context.Context) (api.MetadataOutput, error)
}

type SourceClient interface {
	Stream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (Source_StreamClient, error)
	Metadata(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MetadataResponse, error)
}

type SourceServer interface {
	Stream(*StreamRequest, Source_StreamServer) error
	Metadata(context.Context, *emptypb.Empty) (*MetadataResponse, error)
	// contains filtered or unexported methods
}

type Source_StreamClient interface {
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type Source_StreamServer interface {
	Send(*StreamResponse) error
	grpc.ServerStream
}

type StreamContext struct {
	IsInteractivitySupported bool `protobuf:"varint,1,opt,name=isInteractivitySupported,proto3" json:"isInteractivitySupported,omitempty"`
	// kubeConfig is is kubeConfig represented in bytes
	KubeConfig  []byte `protobuf:"bytes,2,opt,name=kubeConfig,proto3" json:"kubeConfig,omitempty"`
	ClusterName string `protobuf:"bytes,3,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	// contains filtered or unexported fields
}

type StreamInput struct {
	// Configs is a list of Source configurations specified by users.
	Configs []*Config
	// Context holds streaming context.
	Context StreamInputContext
}

type StreamInputContext struct {
	// IsInteractivitySupported is set to true only if communication platform supports interactive Messages.
	IsInteractivitySupported bool

	// KubeConfig is the path to kubectl configuration file.
	KubeConfig []byte

	// ClusterName is the name of underlying Kubernetes cluster which is provided by end user.
	ClusterName string
}

type StreamOutput struct {
	// Output represents the streamed events. It is from start of plugin execution.
	// Deprecated: Use the Message field instead.
	//
	// Migration path:
	//
	//	Old approach:
	//	  out := source.StreamOutput{
	//	  	Output: make(chan []byte),
	//	  }
	//	  go func() {
	//	  	out.Output <- []byte("Ticker Event")
	//	  }()
	//	  return out, nil
	//
	//	New approach:
	//	  out := source.StreamOutput{
	//	  	Event: make(chan source.Event),
	//	  }
	//	  go func() {
	//	  	out.Event <- source.Event{
	//	  		Message: api.NewPlaintextMessage("Ticker Event", true),
	//	  	}
	//	  }()
	//	  return out, nil
	Output chan []byte
	// Event represents the streamed events with message,raw object, and analytics data. It is from start of plugin consumption.
	// You can construct a complex message.data or just use one of our helper functions:
	//   - api.NewCodeBlockMessage("body", true)
	//   - api.NewPlaintextMessage("body", true)
	Event chan Event
}

type StreamRequest struct {

	// Configs is a list of Source configurations specified by users.
	Configs []*Config `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	// context holds context stream.
	Context *StreamContext `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

type StreamResponse struct {

	// Output represents the streamed Source events. It is from start of Source execution.
	Output []byte `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Event  []byte `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedSourceServer struct {
}

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