source

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

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

	// SourceName is the name of the source plugin configuration.
	SourceName string

	IncomingWebhook IncomingWebhookDetailsContext
}

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 ExternalRequest struct {

	// Payload is a payload of a external request.
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// Config is Source configuration specified by users.
	Config *Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// context holds context for external request.
	Context *ExternalRequestContext `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

type ExternalRequestContext struct {
	SourceContext *SourceContext `protobuf:"bytes,1,opt,name=sourceContext,proto3" json:"sourceContext,omitempty"`
	// contains filtered or unexported fields
}

type ExternalRequestInput struct {
	// Payload is the payload of the incoming webhook.
	Payload []byte

	// Config is Source configuration specified by users.
	Config *Config

	// Context holds single dispatch context.
	Context ExternalRequestInputContext
}

type ExternalRequestInputContext struct {
	CommonSourceContext
}

type ExternalRequestMetadata struct {

	// payload is a payload of a external request.
	Payload *ExternalRequestPayloadMetadata `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type ExternalRequestOutput struct {
	// Event represents the streamed events with message, raw object, and analytics data. It is from the 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 Event
}

type ExternalRequestPayloadMetadata struct {

	// json_schema is a JSON schema of a given incoming webhook request body.
	JsonSchema *JSONSchema `protobuf:"bytes,1,opt,name=json_schema,json=jsonSchema,proto3" json:"json_schema,omitempty"`
	// contains filtered or unexported fields
}

type ExternalRequestResponse struct {

	// event is a response of a external request.
	Event []byte `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type HandleExternalRequestUnimplemented struct{}

type IncomingWebhookContext struct {
	BaseURL          string `protobuf:"bytes,1,opt,name=baseURL,proto3" json:"baseURL,omitempty"`
	FullURLForSource string `protobuf:"bytes,2,opt,name=fullURLForSource,proto3" json:"fullURLForSource,omitempty"`
	// contains filtered or unexported fields
}

type IncomingWebhookDetailsContext struct {
	BaseURL          string
	FullURLForSource string
}

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 configuration.
	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 */
	// external_request is a metadata of a given external request.
	ExternalRequest *ExternalRequestMetadata `protobuf:"bytes,5,opt,name=external_request,json=externalRequest,proto3,oneof" json:"external_request,omitempty"`
	// URL to plugin documentation.
	DocumentationUrl string `protobuf:"bytes,6,opt,name=documentation_url,json=documentationUrl,proto3" json:"documentation_url,omitempty"`
	// Recommended plugin recommended
	Recommended bool `protobuf:"varint,7,opt,name=recommended,proto3" json:"recommended,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

type SourceContext struct {
	IsInteractivitySupported bool                    `protobuf:"varint,1,opt,name=isInteractivitySupported,proto3" json:"isInteractivitySupported,omitempty"`
	ClusterName              string                  `protobuf:"bytes,2,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	SourceName               string                  `protobuf:"bytes,3,opt,name=sourceName,proto3" json:"sourceName,omitempty"`
	IncomingWebhook          *IncomingWebhookContext `protobuf:"bytes,4,opt,name=incomingWebhook,proto3" json:"incomingWebhook,omitempty"`
	// contains filtered or unexported fields
}

type SourceServer interface {
	Stream(*StreamRequest, Source_StreamServer) error
	HandleExternalRequest(context.Context, *ExternalRequest) (*ExternalRequestResponse, 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 {
	SourceContext *SourceContext `protobuf:"bytes,1,opt,name=sourceContext,proto3" json:"sourceContext,omitempty"`
	// kubeConfig is is kubeConfig represented in bytes.
	KubeConfig []byte `protobuf:"bytes,2,opt,name=kubeConfig,proto3" json:"kubeConfig,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 {
	// KubeConfig is the path to kubectl configuration file.
	KubeConfig []byte

	CommonSourceContext
}

type StreamOutput struct {
	// Event represents the streamed events with message, raw object, and analytics data. It is from the 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 {
	Event []byte `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type StreamUnimplemented struct{}

type UnimplementedSourceServer struct {
}

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