proto

package
v0.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 26, 2024 License: MPL-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PipelineService_ConfigStruct_FullMethodName       = "/martiancloud.phobos.sdk.PipelineService/ConfigStruct"
	PipelineService_Configure_FullMethodName          = "/martiancloud.phobos.sdk.PipelineService/Configure"
	PipelineService_Shutdown_FullMethodName           = "/martiancloud.phobos.sdk.PipelineService/Shutdown"
	PipelineService_ActionOutputStruct_FullMethodName = "/martiancloud.phobos.sdk.PipelineService/ActionOutputStruct"
	PipelineService_ActionInputStruct_FullMethodName  = "/martiancloud.phobos.sdk.PipelineService/ActionInputStruct"
	PipelineService_ExecuteActionSpec_FullMethodName  = "/martiancloud.phobos.sdk.PipelineService/ExecuteActionSpec"
	PipelineService_ExecuteAction_FullMethodName      = "/martiancloud.phobos.sdk.PipelineService/ExecuteAction"
	PipelineService_Schema_FullMethodName             = "/martiancloud.phobos.sdk.PipelineService/Schema"
)
View Source 
const (
	MetadataService_PluginMetadata_FullMethodName = "/martiancloud.phobos.sdk.MetadataService/PluginMetadata"
)
View Source 
const (
	TerminalUIService_Events_FullMethodName = "/martiancloud.phobos.sdk.TerminalUIService/Events"
)

Variables

View Source 
var (
	FuncSpec_Value_PrimitiveType_name = map[int32]string{
		0:  "INVALID",
		1:  "BOOL",
		2:  "INT",
		3:  "INT8",
		4:  "INT16",
		5:  "INT32",
		6:  "INT64",
		7:  "UINT",
		8:  "UINT8",
		9:  "UINT16",
		10: "UINT32",
		11: "UINT64",
		24: "STRING",
	}
	FuncSpec_Value_PrimitiveType_value = map[string]int32{
		"INVALID": 0,
		"BOOL":    1,
		"INT":     2,
		"INT8":    3,
		"INT16":   4,
		"INT32":   5,
		"INT64":   6,
		"UINT":    7,
		"UINT8":   8,
		"UINT16":  9,
		"UINT32":  10,
		"UINT64":  11,
		"STRING":  24,
	}
)

Enum value maps for FuncSpec_Value_PrimitiveType.

View Source 
var File_plugin_proto protoreflect.FileDescriptor
View Source 
var File_unused_proto protoreflect.FileDescriptor
View Source 
var MetadataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "martiancloud.phobos.sdk.MetadataService",
	HandlerType: (*MetadataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PluginMetadata",
			Handler:    _MetadataService_PluginMetadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugin.proto",
}

MetadataService_ServiceDesc is the grpc.ServiceDesc for MetadataService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var PipelineService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "martiancloud.phobos.sdk.PipelineService",
	HandlerType: (*PipelineServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ConfigStruct",
			Handler:    _PipelineService_ConfigStruct_Handler,
		},
		{
			MethodName: "Configure",
			Handler:    _PipelineService_Configure_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _PipelineService_Shutdown_Handler,
		},
		{
			MethodName: "ActionOutputStruct",
			Handler:    _PipelineService_ActionOutputStruct_Handler,
		},
		{
			MethodName: "ActionInputStruct",
			Handler:    _PipelineService_ActionInputStruct_Handler,
		},
		{
			MethodName: "ExecuteActionSpec",
			Handler:    _PipelineService_ExecuteActionSpec_Handler,
		},
		{
			MethodName: "ExecuteAction",
			Handler:    _PipelineService_ExecuteAction_Handler,
		},
		{
			MethodName: "Schema",
			Handler:    _PipelineService_Schema_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugin.proto",
}

PipelineService_ServiceDesc is the grpc.ServiceDesc for PipelineService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TerminalUIService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "martiancloud.phobos.sdk.TerminalUIService",
	HandlerType: (*TerminalUIServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Events",
			Handler:       _TerminalUIService_Events_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "plugin.proto",
}

TerminalUIService_ServiceDesc is the grpc.ServiceDesc for TerminalUIService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMetadataServiceServer 

func RegisterMetadataServiceServer(s grpc.ServiceRegistrar, srv MetadataServiceServer)

func RegisterPipelineServiceServer 

func RegisterPipelineServiceServer(s grpc.ServiceRegistrar, srv PipelineServiceServer)

func RegisterTerminalUIServiceServer 

func RegisterTerminalUIServiceServer(s grpc.ServiceRegistrar, srv TerminalUIServiceServer)

Types

type Args 

type Args struct {
	// contains filtered or unexported fields
}

Args are the common argument types that are available to many of the dynamic functions. The exact list of available argument types is available on the Go interface docs.

func (*Args) Descriptor deprecated 

func (*Args) Descriptor() ([]byte, []int)

Deprecated: Use Args.ProtoReflect.Descriptor instead.

func (*Args) ProtoMessage 

func (*Args) ProtoMessage()

func (*Args) ProtoReflect 

func (x *Args) ProtoReflect() protoreflect.Message

func (*Args) Reset 

func (x *Args) Reset()

func (*Args) String 

func (x *Args) String() string

type Args_Logger 

type Args_Logger struct {

	// name is the name of the logger
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Logger is used to construct an logger for the plugin.

func (*Args_Logger) Descriptor deprecated 

func (*Args_Logger) Descriptor() ([]byte, []int)

Deprecated: Use Args_Logger.ProtoReflect.Descriptor instead.

func (*Args_Logger) GetName 

func (x *Args_Logger) GetName() string

func (*Args_Logger) ProtoMessage 

func (*Args_Logger) ProtoMessage()

func (*Args_Logger) ProtoReflect 

func (x *Args_Logger) ProtoReflect() protoreflect.Message

func (*Args_Logger) Reset 

func (x *Args_Logger) Reset()

func (*Args_Logger) String 

func (x *Args_Logger) String() string

type Args_TerminalUI 

type Args_TerminalUI struct {
	StreamId uint32 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

TerminalUI is used to construct the terminal.UI for the plugin.

func (*Args_TerminalUI) Descriptor deprecated 

func (*Args_TerminalUI) Descriptor() ([]byte, []int)

Deprecated: Use Args_TerminalUI.ProtoReflect.Descriptor instead.

func (*Args_TerminalUI) GetStreamId 

func (x *Args_TerminalUI) GetStreamId() uint32

func (*Args_TerminalUI) ProtoMessage 

func (*Args_TerminalUI) ProtoMessage()

func (*Args_TerminalUI) ProtoReflect 

func (x *Args_TerminalUI) ProtoReflect() protoreflect.Message

func (*Args_TerminalUI) Reset 

func (x *Args_TerminalUI) Reset()

func (*Args_TerminalUI) String 

func (x *Args_TerminalUI) String() string

type Config 

type Config struct {
	// contains filtered or unexported fields
}

Config is the namespace of messages related to configuration.

All components that take configuration are expected to have two RPC calls:

  • ConfigStruct - Returns the configuration structure.
  • Configure - Sends the configuration data back to the plugin and the plugin is also expected to perform any validation at this stage.

func (*Config) Descriptor deprecated 

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type Config_ConfigureRequest 

type Config_ConfigureRequest struct {

	// json is the json data for the structure returned in the StructResp.
	// It is guaranteed to decode cleanly into the target structure.
	Json []byte `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"`
	// contains filtered or unexported fields
}

ConfigureRequest is the request sent once the configuration decoding is complete to actually assign the values to the structure.

func (*Config_ConfigureRequest) Descriptor deprecated 

func (*Config_ConfigureRequest) Descriptor() ([]byte, []int)

Deprecated: Use Config_ConfigureRequest.ProtoReflect.Descriptor instead.

func (*Config_ConfigureRequest) GetJson 

func (x *Config_ConfigureRequest) GetJson() []byte

func (*Config_ConfigureRequest) ProtoMessage 

func (*Config_ConfigureRequest) ProtoMessage()

func (*Config_ConfigureRequest) ProtoReflect 

func (x *Config_ConfigureRequest) ProtoReflect() protoreflect.Message

func (*Config_ConfigureRequest) Reset 

func (x *Config_ConfigureRequest) Reset()

func (*Config_ConfigureRequest) String 

func (x *Config_ConfigureRequest) String() string

type Config_StructResp 

type Config_StructResp struct {

	// struct is the configuration structure (or empty/nil if one doesn't exist).
	// This struct should have all the proper struct tags for HCL decoding
	// You should do validation on the Configure call.
	Struct *protostructure.Struct `protobuf:"bytes,1,opt,name=struct,proto3" json:"struct,omitempty"`
	// contains filtered or unexported fields
}

StructResp returns the struct for configuration.

func (*Config_StructResp) Descriptor deprecated 

func (*Config_StructResp) Descriptor() ([]byte, []int)

Deprecated: Use Config_StructResp.ProtoReflect.Descriptor instead.

func (*Config_StructResp) GetStruct 

func (x *Config_StructResp) GetStruct() *protostructure.Struct

func (*Config_StructResp) ProtoMessage 

func (*Config_StructResp) ProtoMessage()

func (*Config_StructResp) ProtoReflect 

func (x *Config_StructResp) ProtoReflect() protoreflect.Message

func (*Config_StructResp) Reset 

func (x *Config_StructResp) Reset()

func (*Config_StructResp) String 

func (x *Config_StructResp) String() string

type FuncSpec 

type FuncSpec struct {

	// name of the function. This is used for improved logging.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// args is the list of arguments by protobuf Any types.
	Args []*FuncSpec_Value `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

FuncSpec describes a function and is used by the dependency-injection framework to provide the function with the proper values.

Value types are specified using strings. Built-in framework types are defined via constants in the `sdk` package. For custom types, you can use whatever string as long as it is unique. We recommend using a unique prefix plus the Go type name.

func (*FuncSpec) Descriptor deprecated 

func (*FuncSpec) Descriptor() ([]byte, []int)

Deprecated: Use FuncSpec.ProtoReflect.Descriptor instead.

func (*FuncSpec) GetArgs 

func (x *FuncSpec) GetArgs() []*FuncSpec_Value

func (*FuncSpec) GetName 

func (x *FuncSpec) GetName() string

func (*FuncSpec) ProtoMessage 

func (*FuncSpec) ProtoMessage()

func (*FuncSpec) ProtoReflect 

func (x *FuncSpec) ProtoReflect() protoreflect.Message

func (*FuncSpec) Reset 

func (x *FuncSpec) Reset()

func (*FuncSpec) String 

func (x *FuncSpec) String() string

type FuncSpec_Args 

type FuncSpec_Args struct {

	// args is the list of arguments. This will include some of the
	// standard types in this file (in the Args message namespace) as well
	// as custom types declared by the FuncSpec that the plugin is expected
	// to understand how to decode.
	Args []*FuncSpec_Value `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

Args is the standard argument type for an RPC that is calling a FuncSpec.

func (*FuncSpec_Args) Descriptor deprecated 

func (*FuncSpec_Args) Descriptor() ([]byte, []int)

Deprecated: Use FuncSpec_Args.ProtoReflect.Descriptor instead.

func (*FuncSpec_Args) GetArgs 

func (x *FuncSpec_Args) GetArgs() []*FuncSpec_Value

func (*FuncSpec_Args) ProtoMessage 

func (*FuncSpec_Args) ProtoMessage()

func (*FuncSpec_Args) ProtoReflect 

func (x *FuncSpec_Args) ProtoReflect() protoreflect.Message

func (*FuncSpec_Args) Reset 

func (x *FuncSpec_Args) Reset()

func (*FuncSpec_Args) String 

func (x *FuncSpec_Args) String() string

type FuncSpec_Value 

type FuncSpec_Value struct {

	// name is the name of the argument. This may be empty for typed arguments.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// type is the type of the argument. All arguments encoded using *opaqueany.Any
	// specify the proto Any message type and not a language-specific type.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// primitive_type is set to a non-zero if the type is NOT an *opaqueany.Any.
	PrimitiveType FuncSpec_Value_PrimitiveType `` /* 159-byte string literal not displayed */
	// value for this Value. This is only set for Args and has no impact on specs.
	// This value MUST match the type or primitive_type fields.
	//
	// Types that are assignable to Value:
	//
	//	*FuncSpec_Value_ProtoAny
	//	*FuncSpec_Value_Bool
	//	*FuncSpec_Value_Int
	//	*FuncSpec_Value_Uint
	//	*FuncSpec_Value_String_
	Value isFuncSpec_Value_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*FuncSpec_Value) Descriptor deprecated 

func (*FuncSpec_Value) Descriptor() ([]byte, []int)

Deprecated: Use FuncSpec_Value.ProtoReflect.Descriptor instead.

func (*FuncSpec_Value) GetBool 

func (x *FuncSpec_Value) GetBool() bool

func (*FuncSpec_Value) GetInt 

func (x *FuncSpec_Value) GetInt() int64

func (*FuncSpec_Value) GetName 

func (x *FuncSpec_Value) GetName() string

func (*FuncSpec_Value) GetPrimitiveType 

func (x *FuncSpec_Value) GetPrimitiveType() FuncSpec_Value_PrimitiveType

func (*FuncSpec_Value) GetProtoAny 

func (x *FuncSpec_Value) GetProtoAny() *opaqueany.Any

func (*FuncSpec_Value) GetString_ 

func (x *FuncSpec_Value) GetString_() string

func (*FuncSpec_Value) GetType 

func (x *FuncSpec_Value) GetType() string

func (*FuncSpec_Value) GetUint 

func (x *FuncSpec_Value) GetUint() uint64

func (*FuncSpec_Value) GetValue 

func (m *FuncSpec_Value) GetValue() isFuncSpec_Value_Value

func (*FuncSpec_Value) ProtoMessage 

func (*FuncSpec_Value) ProtoMessage()

func (*FuncSpec_Value) ProtoReflect 

func (x *FuncSpec_Value) ProtoReflect() protoreflect.Message

func (*FuncSpec_Value) Reset 

func (x *FuncSpec_Value) Reset()

func (*FuncSpec_Value) String 

func (x *FuncSpec_Value) String() string

type FuncSpec_Value_Bool 

type FuncSpec_Value_Bool struct {
	// Primitive values below
	Bool bool `protobuf:"varint,5,opt,name=bool,proto3,oneof"`
}

type FuncSpec_Value_Int 

type FuncSpec_Value_Int struct {
	Int int64 `protobuf:"varint,6,opt,name=int,proto3,oneof"` // all sizes up to 64-bit
}

type FuncSpec_Value_PrimitiveType 

type FuncSpec_Value_PrimitiveType int32

PrimitiveType are the types of primitives we support. The enum value must exactly match the Go reflect.Kind enum value. 

const (
	FuncSpec_Value_INVALID FuncSpec_Value_PrimitiveType = 0
	FuncSpec_Value_BOOL    FuncSpec_Value_PrimitiveType = 1
	FuncSpec_Value_INT     FuncSpec_Value_PrimitiveType = 2
	FuncSpec_Value_INT8    FuncSpec_Value_PrimitiveType = 3
	FuncSpec_Value_INT16   FuncSpec_Value_PrimitiveType = 4
	FuncSpec_Value_INT32   FuncSpec_Value_PrimitiveType = 5
	FuncSpec_Value_INT64   FuncSpec_Value_PrimitiveType = 6
	FuncSpec_Value_UINT    FuncSpec_Value_PrimitiveType = 7
	FuncSpec_Value_UINT8   FuncSpec_Value_PrimitiveType = 8
	FuncSpec_Value_UINT16  FuncSpec_Value_PrimitiveType = 9
	FuncSpec_Value_UINT32  FuncSpec_Value_PrimitiveType = 10
	FuncSpec_Value_UINT64  FuncSpec_Value_PrimitiveType = 11
	FuncSpec_Value_STRING  FuncSpec_Value_PrimitiveType = 24
)

func (FuncSpec_Value_PrimitiveType) Descriptor 

func (FuncSpec_Value_PrimitiveType) Descriptor() protoreflect.EnumDescriptor

func (FuncSpec_Value_PrimitiveType) Enum 

func (x FuncSpec_Value_PrimitiveType) Enum() *FuncSpec_Value_PrimitiveType

func (FuncSpec_Value_PrimitiveType) EnumDescriptor deprecated 

func (FuncSpec_Value_PrimitiveType) EnumDescriptor() ([]byte, []int)

Deprecated: Use FuncSpec_Value_PrimitiveType.Descriptor instead.

func (FuncSpec_Value_PrimitiveType) Number 

func (x FuncSpec_Value_PrimitiveType) Number() protoreflect.EnumNumber

func (FuncSpec_Value_PrimitiveType) String 

func (x FuncSpec_Value_PrimitiveType) String() string

func (FuncSpec_Value_PrimitiveType) Type 

func (FuncSpec_Value_PrimitiveType) Type() protoreflect.EnumType

type FuncSpec_Value_ProtoAny 

type FuncSpec_Value_ProtoAny struct {
	// proto is set if the value is a protobuf message.
	ProtoAny *opaqueany.Any `protobuf:"bytes,3,opt,name=proto_any,json=protoAny,proto3,oneof"`
}

type FuncSpec_Value_String_ 

type FuncSpec_Value_String_ struct {
	String_ string `protobuf:"bytes,8,opt,name=string,proto3,oneof"`
}

type FuncSpec_Value_Uint 

type FuncSpec_Value_Uint struct {
	Uint uint64 `protobuf:"varint,7,opt,name=uint,proto3,oneof"` // all sizes up to 64-bit
}

type Metadata 

type Metadata struct {
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

func (*Metadata) Descriptor() ([]byte, []int)

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type MetadataServiceClient 

type MetadataServiceClient interface {
	PluginMetadata(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Metadata_Plugin, error)
}

MetadataServiceClient is the client API for MetadataService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMetadataServiceClient 

func NewMetadataServiceClient(cc grpc.ClientConnInterface) MetadataServiceClient

type MetadataServiceServer 

type MetadataServiceServer interface {
	PluginMetadata(context.Context, *emptypb.Empty) (*Metadata_Plugin, error)
	// contains filtered or unexported methods
}

MetadataServiceServer is the server API for MetadataService service. All implementations must embed UnimplementedMetadataServiceServer for forward compatibility

type Metadata_Plugin 

type Metadata_Plugin struct {
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata_Plugin) Descriptor deprecated 

func (*Metadata_Plugin) Descriptor() ([]byte, []int)

Deprecated: Use Metadata_Plugin.ProtoReflect.Descriptor instead.

func (*Metadata_Plugin) GetDescription 

func (x *Metadata_Plugin) GetDescription() string

func (*Metadata_Plugin) ProtoMessage 

func (*Metadata_Plugin) ProtoMessage()

func (*Metadata_Plugin) ProtoReflect 

func (x *Metadata_Plugin) ProtoReflect() protoreflect.Message

func (*Metadata_Plugin) Reset 

func (x *Metadata_Plugin) Reset()

func (*Metadata_Plugin) String 

func (x *Metadata_Plugin) String() string

type Pipeline 

type Pipeline struct {
	// contains filtered or unexported fields
}

func (*Pipeline) Descriptor deprecated 

func (*Pipeline) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.

func (*Pipeline) ProtoMessage 

func (*Pipeline) ProtoMessage()

func (*Pipeline) ProtoReflect 

func (x *Pipeline) ProtoReflect() protoreflect.Message

func (*Pipeline) Reset 

func (x *Pipeline) Reset()

func (*Pipeline) String 

func (x *Pipeline) String() string

type PipelineServiceClient 

type PipelineServiceClient interface {
	ConfigStruct(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Config_StructResp, error)
	Configure(ctx context.Context, in *Config_ConfigureRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Shutdown(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ActionOutputStruct(ctx context.Context, in *Pipeline_ActionOutputStructRequest, opts ...grpc.CallOption) (*Config_StructResp, error)
	ActionInputStruct(ctx context.Context, in *Pipeline_ActionInputStructRequest, opts ...grpc.CallOption) (*Config_StructResp, error)
	ExecuteActionSpec(ctx context.Context, in *Pipeline_ExecuteActionSpecRequest, opts ...grpc.CallOption) (*FuncSpec, error)
	ExecuteAction(ctx context.Context, in *Pipeline_ExecuteActionRequest, opts ...grpc.CallOption) (*Pipeline_ExecuteActionResponse, error)
	Schema(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Pipeline_SchemaResponse, error)
}

PipelineServiceClient is the client API for PipelineService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPipelineServiceClient 

func NewPipelineServiceClient(cc grpc.ClientConnInterface) PipelineServiceClient

type PipelineServiceServer 

type PipelineServiceServer interface {
	ConfigStruct(context.Context, *emptypb.Empty) (*Config_StructResp, error)
	Configure(context.Context, *Config_ConfigureRequest) (*emptypb.Empty, error)
	Shutdown(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	ActionOutputStruct(context.Context, *Pipeline_ActionOutputStructRequest) (*Config_StructResp, error)
	ActionInputStruct(context.Context, *Pipeline_ActionInputStructRequest) (*Config_StructResp, error)
	ExecuteActionSpec(context.Context, *Pipeline_ExecuteActionSpecRequest) (*FuncSpec, error)
	ExecuteAction(context.Context, *Pipeline_ExecuteActionRequest) (*Pipeline_ExecuteActionResponse, error)
	Schema(context.Context, *emptypb.Empty) (*Pipeline_SchemaResponse, error)
	// contains filtered or unexported methods
}

PipelineServiceServer is the server API for PipelineService service. All implementations must embed UnimplementedPipelineServiceServer for forward compatibility

type Pipeline_ActionInputStructRequest 

type Pipeline_ActionInputStructRequest struct {
	ActionName string `protobuf:"bytes,1,opt,name=action_name,json=actionName,proto3" json:"action_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Pipeline_ActionInputStructRequest) Descriptor deprecated 

func (*Pipeline_ActionInputStructRequest) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline_ActionInputStructRequest.ProtoReflect.Descriptor instead.

func (*Pipeline_ActionInputStructRequest) GetActionName 

func (x *Pipeline_ActionInputStructRequest) GetActionName() string

func (*Pipeline_ActionInputStructRequest) ProtoMessage 

func (*Pipeline_ActionInputStructRequest) ProtoMessage()

func (*Pipeline_ActionInputStructRequest) ProtoReflect 

func (x *Pipeline_ActionInputStructRequest) ProtoReflect() protoreflect.Message

func (*Pipeline_ActionInputStructRequest) Reset 

func (x *Pipeline_ActionInputStructRequest) Reset()

func (*Pipeline_ActionInputStructRequest) String 

func (x *Pipeline_ActionInputStructRequest) String() string

type Pipeline_ActionOutputStructRequest 

type Pipeline_ActionOutputStructRequest struct {
	ActionName string `protobuf:"bytes,1,opt,name=action_name,json=actionName,proto3" json:"action_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Pipeline_ActionOutputStructRequest) Descriptor deprecated 

func (*Pipeline_ActionOutputStructRequest) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline_ActionOutputStructRequest.ProtoReflect.Descriptor instead.

func (*Pipeline_ActionOutputStructRequest) GetActionName 

func (x *Pipeline_ActionOutputStructRequest) GetActionName() string

func (*Pipeline_ActionOutputStructRequest) ProtoMessage 

func (*Pipeline_ActionOutputStructRequest) ProtoMessage()

func (*Pipeline_ActionOutputStructRequest) ProtoReflect 

func (x *Pipeline_ActionOutputStructRequest) ProtoReflect() protoreflect.Message

func (*Pipeline_ActionOutputStructRequest) Reset 

func (x *Pipeline_ActionOutputStructRequest) Reset()

func (*Pipeline_ActionOutputStructRequest) String 

func (x *Pipeline_ActionOutputStructRequest) String() string

type Pipeline_ActionSchema 

type Pipeline_ActionSchema struct {
	Description string                             `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Group       string                             `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	Input       *Plugin_SchemaBlock                `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	Outputs     map[string]*Plugin_SchemaAttribute `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Pipeline_ActionSchema) Descriptor deprecated 

func (*Pipeline_ActionSchema) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline_ActionSchema.ProtoReflect.Descriptor instead.

func (*Pipeline_ActionSchema) GetDescription 

func (x *Pipeline_ActionSchema) GetDescription() string

func (*Pipeline_ActionSchema) GetGroup added in v0.3.0 

func (x *Pipeline_ActionSchema) GetGroup() string

func (*Pipeline_ActionSchema) GetInput 

func (x *Pipeline_ActionSchema) GetInput() *Plugin_SchemaBlock

func (*Pipeline_ActionSchema) GetOutputs 

func (x *Pipeline_ActionSchema) GetOutputs() map[string]*Plugin_SchemaAttribute

func (*Pipeline_ActionSchema) ProtoMessage 

func (*Pipeline_ActionSchema) ProtoMessage()

func (*Pipeline_ActionSchema) ProtoReflect 

func (x *Pipeline_ActionSchema) ProtoReflect() protoreflect.Message

func (*Pipeline_ActionSchema) Reset 

func (x *Pipeline_ActionSchema) Reset()

func (*Pipeline_ActionSchema) String 

func (x *Pipeline_ActionSchema) String() string

type Pipeline_ExecuteActionRequest 

type Pipeline_ExecuteActionRequest struct {
	ActionName string         `protobuf:"bytes,1,opt,name=action_name,json=actionName,proto3" json:"action_name,omitempty"`
	Json       []byte         `protobuf:"bytes,2,opt,name=json,proto3" json:"json,omitempty"`
	Args       *FuncSpec_Args `protobuf:"bytes,3,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*Pipeline_ExecuteActionRequest) Descriptor deprecated 

func (*Pipeline_ExecuteActionRequest) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline_ExecuteActionRequest.ProtoReflect.Descriptor instead.

func (*Pipeline_ExecuteActionRequest) GetActionName 

func (x *Pipeline_ExecuteActionRequest) GetActionName() string

func (*Pipeline_ExecuteActionRequest) GetArgs 

func (x *Pipeline_ExecuteActionRequest) GetArgs() *FuncSpec_Args

func (*Pipeline_ExecuteActionRequest) GetJson 

func (x *Pipeline_ExecuteActionRequest) GetJson() []byte

func (*Pipeline_ExecuteActionRequest) ProtoMessage 

func (*Pipeline_ExecuteActionRequest) ProtoMessage()

func (*Pipeline_ExecuteActionRequest) ProtoReflect 

func (x *Pipeline_ExecuteActionRequest) ProtoReflect() protoreflect.Message

func (*Pipeline_ExecuteActionRequest) Reset 

func (x *Pipeline_ExecuteActionRequest) Reset()

func (*Pipeline_ExecuteActionRequest) String 

func (x *Pipeline_ExecuteActionRequest) String() string

type Pipeline_ExecuteActionResponse 

type Pipeline_ExecuteActionResponse struct {
	OutputValue []byte `protobuf:"bytes,1,opt,name=output_value,json=outputValue,proto3" json:"output_value,omitempty"`
	OutputType  []byte `protobuf:"bytes,2,opt,name=output_type,json=outputType,proto3" json:"output_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Pipeline_ExecuteActionResponse) Descriptor deprecated 

func (*Pipeline_ExecuteActionResponse) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline_ExecuteActionResponse.ProtoReflect.Descriptor instead.

func (*Pipeline_ExecuteActionResponse) GetOutputType 

func (x *Pipeline_ExecuteActionResponse) GetOutputType() []byte

func (*Pipeline_ExecuteActionResponse) GetOutputValue 

func (x *Pipeline_ExecuteActionResponse) GetOutputValue() []byte

func (*Pipeline_ExecuteActionResponse) ProtoMessage 

func (*Pipeline_ExecuteActionResponse) ProtoMessage()

func (*Pipeline_ExecuteActionResponse) ProtoReflect 

func (x *Pipeline_ExecuteActionResponse) ProtoReflect() protoreflect.Message

func (*Pipeline_ExecuteActionResponse) Reset 

func (x *Pipeline_ExecuteActionResponse) Reset()

func (*Pipeline_ExecuteActionResponse) String 

func (x *Pipeline_ExecuteActionResponse) String() string

type Pipeline_ExecuteActionSpecRequest 

type Pipeline_ExecuteActionSpecRequest struct {
	ActionName string `protobuf:"bytes,1,opt,name=action_name,json=actionName,proto3" json:"action_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Pipeline_ExecuteActionSpecRequest) Descriptor deprecated 

func (*Pipeline_ExecuteActionSpecRequest) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline_ExecuteActionSpecRequest.ProtoReflect.Descriptor instead.

func (*Pipeline_ExecuteActionSpecRequest) GetActionName 

func (x *Pipeline_ExecuteActionSpecRequest) GetActionName() string

func (*Pipeline_ExecuteActionSpecRequest) ProtoMessage 

func (*Pipeline_ExecuteActionSpecRequest) ProtoMessage()

func (*Pipeline_ExecuteActionSpecRequest) ProtoReflect 

func (x *Pipeline_ExecuteActionSpecRequest) ProtoReflect() protoreflect.Message

func (*Pipeline_ExecuteActionSpecRequest) Reset 

func (x *Pipeline_ExecuteActionSpecRequest) Reset()

func (*Pipeline_ExecuteActionSpecRequest) String 

func (x *Pipeline_ExecuteActionSpecRequest) String() string

type Pipeline_SchemaResponse 

type Pipeline_SchemaResponse struct {
	Config  *Plugin_SchemaBlock               `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Actions map[string]*Pipeline_ActionSchema `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Pipeline_SchemaResponse) Descriptor deprecated 

func (*Pipeline_SchemaResponse) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline_SchemaResponse.ProtoReflect.Descriptor instead.

func (*Pipeline_SchemaResponse) GetActions 

func (x *Pipeline_SchemaResponse) GetActions() map[string]*Pipeline_ActionSchema

func (*Pipeline_SchemaResponse) GetConfig 

func (x *Pipeline_SchemaResponse) GetConfig() *Plugin_SchemaBlock

func (*Pipeline_SchemaResponse) ProtoMessage 

func (*Pipeline_SchemaResponse) ProtoMessage()

func (*Pipeline_SchemaResponse) ProtoReflect 

func (x *Pipeline_SchemaResponse) ProtoReflect() protoreflect.Message

func (*Pipeline_SchemaResponse) Reset 

func (x *Pipeline_SchemaResponse) Reset()

func (*Pipeline_SchemaResponse) String 

func (x *Pipeline_SchemaResponse) String() string

type Plugin 

type Plugin struct {
	// contains filtered or unexported fields
}

func (*Plugin) Descriptor deprecated 

func (*Plugin) Descriptor() ([]byte, []int)

Deprecated: Use Plugin.ProtoReflect.Descriptor instead.

func (*Plugin) ProtoMessage 

func (*Plugin) ProtoMessage()

func (*Plugin) ProtoReflect 

func (x *Plugin) ProtoReflect() protoreflect.Message

func (*Plugin) Reset 

func (x *Plugin) Reset()

func (*Plugin) String 

func (x *Plugin) String() string

type Plugin_SchemaAttribute 

type Plugin_SchemaAttribute struct {
	Name             string                             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description      string                             `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Type             []byte                             `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Required         *bool                              `protobuf:"varint,4,opt,name=required,proto3,oneof" json:"required,omitempty"`
	Deprecated       bool                               `protobuf:"varint,5,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
	NestedAttributes map[string]*Plugin_SchemaAttribute `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Plugin_SchemaAttribute) Descriptor deprecated 

func (*Plugin_SchemaAttribute) Descriptor() ([]byte, []int)

Deprecated: Use Plugin_SchemaAttribute.ProtoReflect.Descriptor instead.

func (*Plugin_SchemaAttribute) GetDeprecated 

func (x *Plugin_SchemaAttribute) GetDeprecated() bool

func (*Plugin_SchemaAttribute) GetDescription 

func (x *Plugin_SchemaAttribute) GetDescription() string

func (*Plugin_SchemaAttribute) GetName 

func (x *Plugin_SchemaAttribute) GetName() string

func (*Plugin_SchemaAttribute) GetNestedAttributes 

func (x *Plugin_SchemaAttribute) GetNestedAttributes() map[string]*Plugin_SchemaAttribute

func (*Plugin_SchemaAttribute) GetRequired 

func (x *Plugin_SchemaAttribute) GetRequired() bool

func (*Plugin_SchemaAttribute) GetType 

func (x *Plugin_SchemaAttribute) GetType() []byte

func (*Plugin_SchemaAttribute) ProtoMessage 

func (*Plugin_SchemaAttribute) ProtoMessage()

func (*Plugin_SchemaAttribute) ProtoReflect 

func (x *Plugin_SchemaAttribute) ProtoReflect() protoreflect.Message

func (*Plugin_SchemaAttribute) Reset 

func (x *Plugin_SchemaAttribute) Reset()

func (*Plugin_SchemaAttribute) String 

func (x *Plugin_SchemaAttribute) String() string

type Plugin_SchemaBlock 

type Plugin_SchemaBlock struct {
	Attributes map[string]*Plugin_SchemaAttribute `` /* 161-byte string literal not displayed */
	BlockSpecs map[string]*Plugin_SchemaBlockSpec `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Plugin_SchemaBlock) Descriptor deprecated 

func (*Plugin_SchemaBlock) Descriptor() ([]byte, []int)

Deprecated: Use Plugin_SchemaBlock.ProtoReflect.Descriptor instead.

func (*Plugin_SchemaBlock) GetAttributes 

func (x *Plugin_SchemaBlock) GetAttributes() map[string]*Plugin_SchemaAttribute

func (*Plugin_SchemaBlock) GetBlockSpecs 

func (x *Plugin_SchemaBlock) GetBlockSpecs() map[string]*Plugin_SchemaBlockSpec

func (*Plugin_SchemaBlock) ProtoMessage 

func (*Plugin_SchemaBlock) ProtoMessage()

func (*Plugin_SchemaBlock) ProtoReflect 

func (x *Plugin_SchemaBlock) ProtoReflect() protoreflect.Message

func (*Plugin_SchemaBlock) Reset 

func (x *Plugin_SchemaBlock) Reset()

func (*Plugin_SchemaBlock) String 

func (x *Plugin_SchemaBlock) String() string

type Plugin_SchemaBlockSpec 

type Plugin_SchemaBlockSpec struct {
	Name        string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string              `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Type        []byte              `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Required    bool                `protobuf:"varint,4,opt,name=required,proto3" json:"required,omitempty"`
	Deprecated  bool                `protobuf:"varint,5,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
	Block       *Plugin_SchemaBlock `protobuf:"bytes,6,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

func (*Plugin_SchemaBlockSpec) Descriptor deprecated 

func (*Plugin_SchemaBlockSpec) Descriptor() ([]byte, []int)

Deprecated: Use Plugin_SchemaBlockSpec.ProtoReflect.Descriptor instead.

func (*Plugin_SchemaBlockSpec) GetBlock 

func (x *Plugin_SchemaBlockSpec) GetBlock() *Plugin_SchemaBlock

func (*Plugin_SchemaBlockSpec) GetDeprecated 

func (x *Plugin_SchemaBlockSpec) GetDeprecated() bool

func (*Plugin_SchemaBlockSpec) GetDescription 

func (x *Plugin_SchemaBlockSpec) GetDescription() string

func (*Plugin_SchemaBlockSpec) GetName 

func (x *Plugin_SchemaBlockSpec) GetName() string

func (*Plugin_SchemaBlockSpec) GetRequired 

func (x *Plugin_SchemaBlockSpec) GetRequired() bool

func (*Plugin_SchemaBlockSpec) GetType 

func (x *Plugin_SchemaBlockSpec) GetType() []byte

func (*Plugin_SchemaBlockSpec) ProtoMessage 

func (*Plugin_SchemaBlockSpec) ProtoMessage()

func (*Plugin_SchemaBlockSpec) ProtoReflect 

func (x *Plugin_SchemaBlockSpec) ProtoReflect() protoreflect.Message

func (*Plugin_SchemaBlockSpec) Reset 

func (x *Plugin_SchemaBlockSpec) Reset()

func (*Plugin_SchemaBlockSpec) String 

func (x *Plugin_SchemaBlockSpec) String() string

type TerminalUI 

type TerminalUI struct {
	// contains filtered or unexported fields
}

func (*TerminalUI) Descriptor deprecated 

func (*TerminalUI) Descriptor() ([]byte, []int)

Deprecated: Use TerminalUI.ProtoReflect.Descriptor instead.

func (*TerminalUI) ProtoMessage 

func (*TerminalUI) ProtoMessage()

func (*TerminalUI) ProtoReflect 

func (x *TerminalUI) ProtoReflect() protoreflect.Message

func (*TerminalUI) Reset 

func (x *TerminalUI) Reset()

func (*TerminalUI) String 

func (x *TerminalUI) String() string

type TerminalUIServiceClient 

type TerminalUIServiceClient interface {
	Events(ctx context.Context, opts ...grpc.CallOption) (TerminalUIService_EventsClient, error)
}

TerminalUIServiceClient is the client API for TerminalUIService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTerminalUIServiceClient 

func NewTerminalUIServiceClient(cc grpc.ClientConnInterface) TerminalUIServiceClient

type TerminalUIServiceServer 

type TerminalUIServiceServer interface {
	Events(TerminalUIService_EventsServer) error
	// contains filtered or unexported methods
}

TerminalUIServiceServer is the server API for TerminalUIService service. All implementations must embed UnimplementedTerminalUIServiceServer for forward compatibility

type TerminalUIService_EventsClient 

type TerminalUIService_EventsClient interface {
	Send(*TerminalUI_Event) error
	Recv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type TerminalUIService_EventsServer 

type TerminalUIService_EventsServer interface {
	Send(*emptypb.Empty) error
	Recv() (*TerminalUI_Event, error)
	grpc.ServerStream
}

type TerminalUI_Event 

type TerminalUI_Event struct {

	// Types that are assignable to Event:
	//
	//	*TerminalUI_Event_Line_
	//	*TerminalUI_Event_NamedValues_
	//	*TerminalUI_Event_Raw_
	//	*TerminalUI_Event_Table_
	Event isTerminalUI_Event_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*TerminalUI_Event) Descriptor deprecated 

func (*TerminalUI_Event) Descriptor() ([]byte, []int)

Deprecated: Use TerminalUI_Event.ProtoReflect.Descriptor instead.

func (*TerminalUI_Event) GetEvent 

func (m *TerminalUI_Event) GetEvent() isTerminalUI_Event_Event

func (*TerminalUI_Event) GetLine 

func (x *TerminalUI_Event) GetLine() *TerminalUI_Event_Line

func (*TerminalUI_Event) GetNamedValues 

func (x *TerminalUI_Event) GetNamedValues() *TerminalUI_Event_NamedValues

func (*TerminalUI_Event) GetRaw 

func (x *TerminalUI_Event) GetRaw() *TerminalUI_Event_Raw

func (*TerminalUI_Event) GetTable 

func (x *TerminalUI_Event) GetTable() *TerminalUI_Event_Table

func (*TerminalUI_Event) ProtoMessage 

func (*TerminalUI_Event) ProtoMessage()

func (*TerminalUI_Event) ProtoReflect 

func (x *TerminalUI_Event) ProtoReflect() protoreflect.Message

func (*TerminalUI_Event) Reset 

func (x *TerminalUI_Event) Reset()

func (*TerminalUI_Event) String 

func (x *TerminalUI_Event) String() string

type TerminalUI_Event_Line 

type TerminalUI_Event_Line struct {
	Msg   string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Style string `protobuf:"bytes,2,opt,name=style,proto3" json:"style,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminalUI_Event_Line) Descriptor deprecated 

func (*TerminalUI_Event_Line) Descriptor() ([]byte, []int)

Deprecated: Use TerminalUI_Event_Line.ProtoReflect.Descriptor instead.

func (*TerminalUI_Event_Line) GetMsg 

func (x *TerminalUI_Event_Line) GetMsg() string

func (*TerminalUI_Event_Line) GetStyle 

func (x *TerminalUI_Event_Line) GetStyle() string

func (*TerminalUI_Event_Line) ProtoMessage 

func (*TerminalUI_Event_Line) ProtoMessage()

func (*TerminalUI_Event_Line) ProtoReflect 

func (x *TerminalUI_Event_Line) ProtoReflect() protoreflect.Message

func (*TerminalUI_Event_Line) Reset 

func (x *TerminalUI_Event_Line) Reset()

func (*TerminalUI_Event_Line) String 

func (x *TerminalUI_Event_Line) String() string

type TerminalUI_Event_Line_ 

type TerminalUI_Event_Line_ struct {
	Line *TerminalUI_Event_Line `protobuf:"bytes,1,opt,name=line,proto3,oneof"`
}

type TerminalUI_Event_NamedValue 

type TerminalUI_Event_NamedValue struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminalUI_Event_NamedValue) Descriptor deprecated 

func (*TerminalUI_Event_NamedValue) Descriptor() ([]byte, []int)

Deprecated: Use TerminalUI_Event_NamedValue.ProtoReflect.Descriptor instead.

func (*TerminalUI_Event_NamedValue) GetName 

func (x *TerminalUI_Event_NamedValue) GetName() string

func (*TerminalUI_Event_NamedValue) GetValue 

func (x *TerminalUI_Event_NamedValue) GetValue() string

func (*TerminalUI_Event_NamedValue) ProtoMessage 

func (*TerminalUI_Event_NamedValue) ProtoMessage()

func (*TerminalUI_Event_NamedValue) ProtoReflect 

func (x *TerminalUI_Event_NamedValue) ProtoReflect() protoreflect.Message

func (*TerminalUI_Event_NamedValue) Reset 

func (x *TerminalUI_Event_NamedValue) Reset()

func (*TerminalUI_Event_NamedValue) String 

func (x *TerminalUI_Event_NamedValue) String() string

type TerminalUI_Event_NamedValues 

type TerminalUI_Event_NamedValues struct {
	Values []*TerminalUI_Event_NamedValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminalUI_Event_NamedValues) Descriptor deprecated 

func (*TerminalUI_Event_NamedValues) Descriptor() ([]byte, []int)

Deprecated: Use TerminalUI_Event_NamedValues.ProtoReflect.Descriptor instead.

func (*TerminalUI_Event_NamedValues) GetValues 

func (x *TerminalUI_Event_NamedValues) GetValues() []*TerminalUI_Event_NamedValue

func (*TerminalUI_Event_NamedValues) ProtoMessage 

func (*TerminalUI_Event_NamedValues) ProtoMessage()

func (*TerminalUI_Event_NamedValues) ProtoReflect 

func (x *TerminalUI_Event_NamedValues) ProtoReflect() protoreflect.Message

func (*TerminalUI_Event_NamedValues) Reset 

func (x *TerminalUI_Event_NamedValues) Reset()

func (*TerminalUI_Event_NamedValues) String 

func (x *TerminalUI_Event_NamedValues) String() string

type TerminalUI_Event_NamedValues_ 

type TerminalUI_Event_NamedValues_ struct {
	NamedValues *TerminalUI_Event_NamedValues `protobuf:"bytes,2,opt,name=named_values,json=namedValues,proto3,oneof"`
}

type TerminalUI_Event_Raw 

type TerminalUI_Event_Raw struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminalUI_Event_Raw) Descriptor deprecated 

func (*TerminalUI_Event_Raw) Descriptor() ([]byte, []int)

Deprecated: Use TerminalUI_Event_Raw.ProtoReflect.Descriptor instead.

func (*TerminalUI_Event_Raw) GetData 

func (x *TerminalUI_Event_Raw) GetData() []byte

func (*TerminalUI_Event_Raw) ProtoMessage 

func (*TerminalUI_Event_Raw) ProtoMessage()

func (*TerminalUI_Event_Raw) ProtoReflect 

func (x *TerminalUI_Event_Raw) ProtoReflect() protoreflect.Message

func (*TerminalUI_Event_Raw) Reset 

func (x *TerminalUI_Event_Raw) Reset()

func (*TerminalUI_Event_Raw) String 

func (x *TerminalUI_Event_Raw) String() string

type TerminalUI_Event_Raw_ 

type TerminalUI_Event_Raw_ struct {
	Raw *TerminalUI_Event_Raw `protobuf:"bytes,3,opt,name=raw,proto3,oneof"`
}

type TerminalUI_Event_Table 

type TerminalUI_Event_Table struct {
	Headers []string                     `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"`
	Rows    []*TerminalUI_Event_TableRow `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminalUI_Event_Table) Descriptor deprecated 

func (*TerminalUI_Event_Table) Descriptor() ([]byte, []int)

Deprecated: Use TerminalUI_Event_Table.ProtoReflect.Descriptor instead.

func (*TerminalUI_Event_Table) GetHeaders 

func (x *TerminalUI_Event_Table) GetHeaders() []string

func (*TerminalUI_Event_Table) GetRows 

func (x *TerminalUI_Event_Table) GetRows() []*TerminalUI_Event_TableRow

func (*TerminalUI_Event_Table) ProtoMessage 

func (*TerminalUI_Event_Table) ProtoMessage()

func (*TerminalUI_Event_Table) ProtoReflect 

func (x *TerminalUI_Event_Table) ProtoReflect() protoreflect.Message

func (*TerminalUI_Event_Table) Reset 

func (x *TerminalUI_Event_Table) Reset()

func (*TerminalUI_Event_Table) String 

func (x *TerminalUI_Event_Table) String() string

type TerminalUI_Event_TableEntry 

type TerminalUI_Event_TableEntry struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Color string `protobuf:"bytes,2,opt,name=color,proto3" json:"color,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminalUI_Event_TableEntry) Descriptor deprecated 

func (*TerminalUI_Event_TableEntry) Descriptor() ([]byte, []int)

Deprecated: Use TerminalUI_Event_TableEntry.ProtoReflect.Descriptor instead.

func (*TerminalUI_Event_TableEntry) GetColor 

func (x *TerminalUI_Event_TableEntry) GetColor() string

func (*TerminalUI_Event_TableEntry) GetValue 

func (x *TerminalUI_Event_TableEntry) GetValue() string

func (*TerminalUI_Event_TableEntry) ProtoMessage 

func (*TerminalUI_Event_TableEntry) ProtoMessage()

func (*TerminalUI_Event_TableEntry) ProtoReflect 

func (x *TerminalUI_Event_TableEntry) ProtoReflect() protoreflect.Message

func (*TerminalUI_Event_TableEntry) Reset 

func (x *TerminalUI_Event_TableEntry) Reset()

func (*TerminalUI_Event_TableEntry) String 

func (x *TerminalUI_Event_TableEntry) String() string

type TerminalUI_Event_TableRow 

type TerminalUI_Event_TableRow struct {
	Entries []*TerminalUI_Event_TableEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminalUI_Event_TableRow) Descriptor deprecated 

func (*TerminalUI_Event_TableRow) Descriptor() ([]byte, []int)

Deprecated: Use TerminalUI_Event_TableRow.ProtoReflect.Descriptor instead.

func (*TerminalUI_Event_TableRow) GetEntries 

func (x *TerminalUI_Event_TableRow) GetEntries() []*TerminalUI_Event_TableEntry

func (*TerminalUI_Event_TableRow) ProtoMessage 

func (*TerminalUI_Event_TableRow) ProtoMessage()

func (*TerminalUI_Event_TableRow) ProtoReflect 

func (x *TerminalUI_Event_TableRow) ProtoReflect() protoreflect.Message

func (*TerminalUI_Event_TableRow) Reset 

func (x *TerminalUI_Event_TableRow) Reset()

func (*TerminalUI_Event_TableRow) String 

func (x *TerminalUI_Event_TableRow) String() string

type TerminalUI_Event_Table_ 

type TerminalUI_Event_Table_ struct {
	Table *TerminalUI_Event_Table `protobuf:"bytes,4,opt,name=table,proto3,oneof"`
}

type UnimplementedMetadataServiceServer 

type UnimplementedMetadataServiceServer struct {
}

UnimplementedMetadataServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetadataServiceServer) PluginMetadata 

func (UnimplementedMetadataServiceServer) PluginMetadata(context.Context, *emptypb.Empty) (*Metadata_Plugin, error)

type UnimplementedPipelineServiceServer 

type UnimplementedPipelineServiceServer struct {
}

UnimplementedPipelineServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPipelineServiceServer) ActionInputStruct 

func (UnimplementedPipelineServiceServer) ActionInputStruct(context.Context, *Pipeline_ActionInputStructRequest) (*Config_StructResp, error)

func (UnimplementedPipelineServiceServer) ActionOutputStruct 

func (UnimplementedPipelineServiceServer) ActionOutputStruct(context.Context, *Pipeline_ActionOutputStructRequest) (*Config_StructResp, error)

func (UnimplementedPipelineServiceServer) ConfigStruct 

func (UnimplementedPipelineServiceServer) ConfigStruct(context.Context, *emptypb.Empty) (*Config_StructResp, error)

func (UnimplementedPipelineServiceServer) Configure 

func (UnimplementedPipelineServiceServer) Configure(context.Context, *Config_ConfigureRequest) (*emptypb.Empty, error)

func (UnimplementedPipelineServiceServer) ExecuteAction 

func (UnimplementedPipelineServiceServer) ExecuteAction(context.Context, *Pipeline_ExecuteActionRequest) (*Pipeline_ExecuteActionResponse, error)

func (UnimplementedPipelineServiceServer) ExecuteActionSpec 

func (UnimplementedPipelineServiceServer) ExecuteActionSpec(context.Context, *Pipeline_ExecuteActionSpecRequest) (*FuncSpec, error)

func (UnimplementedPipelineServiceServer) Schema 

func (UnimplementedPipelineServiceServer) Schema(context.Context, *emptypb.Empty) (*Pipeline_SchemaResponse, error)

func (UnimplementedPipelineServiceServer) Shutdown 

func (UnimplementedPipelineServiceServer) Shutdown(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type UnimplementedTerminalUIServiceServer 

type UnimplementedTerminalUIServiceServer struct {
}

UnimplementedTerminalUIServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTerminalUIServiceServer) Events 

func (UnimplementedTerminalUIServiceServer) Events(TerminalUIService_EventsServer) error

type UnsafeMetadataServiceServer 

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

UnsafeMetadataServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetadataServiceServer will result in compilation errors.

type UnsafePipelineServiceServer 

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

UnsafePipelineServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PipelineServiceServer will result in compilation errors.

type UnsafeTerminalUIServiceServer 

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

UnsafeTerminalUIServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TerminalUIServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.