proto

package
v0.0.0-...-fa1d311 Latest Latest
Warning

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

 Go to latest Published: May 16, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PluginService_Status_FullMethodName   = "/eventrunner.plugin.v1.PluginService/Status"
	PluginService_Command_FullMethodName  = "/eventrunner.plugin.v1.PluginService/Command"
	PluginService_Shutdown_FullMethodName = "/eventrunner.plugin.v1.PluginService/Shutdown"
	PluginService_Output_FullMethodName   = "/eventrunner.plugin.v1.PluginService/Output"
	PluginService_Input_FullMethodName    = "/eventrunner.plugin.v1.PluginService/Input"
)
View Source 
const (
	AppService_Result_FullMethodName = "/eventrunner.plugin.v1.AppService/Result"
)

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "STATUS_STARTUP",
		3: "STATUS_READY",
		4: "STATUS_ERROR",
		5: "STATUS_SHUTDOWN",
	}
	Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"STATUS_STARTUP":     1,
		"STATUS_READY":       3,
		"STATUS_ERROR":       4,
		"STATUS_SHUTDOWN":    5,
	}
)

Enum value maps for Status.

View Source 
var (
	Result_name = map[int32]string{
		0: "RESULT_UNSPECIFIED",
		1: "RESULT_SUCCESS",
		2: "RESULT_ERROR",
		3: "RESULT_ASYNC",
	}
	Result_value = map[string]int32{
		"RESULT_UNSPECIFIED": 0,
		"RESULT_SUCCESS":     1,
		"RESULT_ERROR":       2,
		"RESULT_ASYNC":       3,
	}
)

Enum value maps for Result.

View Source 
var AppService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eventrunner.plugin.v1.AppService",
	HandlerType: (*AppServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Result",
			Handler:    _AppService_Result_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "src/plugin/proto/plugin.proto",
}

AppService_ServiceDesc is the grpc.ServiceDesc for AppService 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 File_src_plugin_proto_plugin_proto protoreflect.FileDescriptor
View Source 
var PluginService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eventrunner.plugin.v1.PluginService",
	HandlerType: (*PluginServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Status",
			Handler:    _PluginService_Status_Handler,
		},
		{
			MethodName: "Command",
			Handler:    _PluginService_Command_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _PluginService_Shutdown_Handler,
		},
		{
			MethodName: "Output",
			Handler:    _PluginService_Output_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Input",
			Handler:       _PluginService_Input_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "src/plugin/proto/plugin.proto",
}

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

Functions

func RegisterAppServiceServer 

func RegisterAppServiceServer(s grpc.ServiceRegistrar, srv AppServiceServer)

func RegisterPluginServiceServer 

func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer)

Types

type AppServiceClient 

type AppServiceClient interface {
	Result(ctx context.Context, in *ResultReq, opts ...grpc.CallOption) (*ResultRes, error)
}

AppServiceClient is the client API for AppService 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 NewAppServiceClient 

func NewAppServiceClient(cc grpc.ClientConnInterface) AppServiceClient

type AppServiceServer 

type AppServiceServer interface {
	Result(context.Context, *ResultReq) (*ResultRes, error)
	// contains filtered or unexported methods
}

AppServiceServer is the server API for AppService service. All implementations must embed UnimplementedAppServiceServer for forward compatibility

type CommandReq 

type CommandReq struct {
	Uuid    string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	Data    []byte `protobuf:"bytes,3,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandReq) Descriptor deprecated 

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

Deprecated: Use CommandReq.ProtoReflect.Descriptor instead.

func (*CommandReq) GetCommand 

func (x *CommandReq) GetCommand() string

func (*CommandReq) GetData 

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

func (*CommandReq) GetUuid 

func (x *CommandReq) GetUuid() string

func (*CommandReq) ProtoMessage 

func (*CommandReq) ProtoMessage()

func (*CommandReq) ProtoReflect 

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

func (*CommandReq) Reset 

func (x *CommandReq) Reset()

func (*CommandReq) String 

func (x *CommandReq) String() string

type CommandRes 

type CommandRes struct {
	Uuid    string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	Data    []byte `protobuf:"bytes,3,opt,name=data,proto3,oneof" json:"data,omitempty"`
	Result  Result `protobuf:"varint,4,opt,name=result,proto3,enum=eventrunner.plugin.v1.Result" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandRes) Descriptor deprecated 

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

Deprecated: Use CommandRes.ProtoReflect.Descriptor instead.

func (*CommandRes) GetCommand 

func (x *CommandRes) GetCommand() string

func (*CommandRes) GetData 

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

func (*CommandRes) GetResult 

func (x *CommandRes) GetResult() Result

func (*CommandRes) GetUuid 

func (x *CommandRes) GetUuid() string

func (*CommandRes) ProtoMessage 

func (*CommandRes) ProtoMessage()

func (*CommandRes) ProtoReflect 

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

func (*CommandRes) Reset 

func (x *CommandRes) Reset()

func (*CommandRes) String 

func (x *CommandRes) String() string

type Config 

type Config 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 (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetName 

func (x *Config) GetName() string

func (*Config) GetValue 

func (x *Config) GetValue() string

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 InputReq 

type InputReq struct {
	Configs []*Config `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*InputReq) Descriptor deprecated 

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

Deprecated: Use InputReq.ProtoReflect.Descriptor instead.

func (*InputReq) GetConfigs 

func (x *InputReq) GetConfigs() []*Config

func (*InputReq) ProtoMessage 

func (*InputReq) ProtoMessage()

func (*InputReq) ProtoReflect 

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

func (*InputReq) Reset 

func (x *InputReq) Reset()

func (*InputReq) String 

func (x *InputReq) String() string

type InputRes 

type InputRes struct {
	Uuid     string      `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Topic    string      `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Metadata []*Metadata `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty"`
	Data     []byte      `protobuf:"bytes,4,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*InputRes) Descriptor deprecated 

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

Deprecated: Use InputRes.ProtoReflect.Descriptor instead.

func (*InputRes) GetData 

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

func (*InputRes) GetMetadata 

func (x *InputRes) GetMetadata() []*Metadata

func (*InputRes) GetTopic 

func (x *InputRes) GetTopic() string

func (*InputRes) GetUuid 

func (x *InputRes) GetUuid() string

func (*InputRes) ProtoMessage 

func (*InputRes) ProtoMessage()

func (*InputRes) ProtoReflect 

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

func (*InputRes) Reset 

func (x *InputRes) Reset()

func (*InputRes) String 

func (x *InputRes) String() string

type Metadata 

type Metadata 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 (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetName 

func (x *Metadata) GetName() string

func (*Metadata) GetValue 

func (x *Metadata) GetValue() string

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 OutputReq 

type OutputReq struct {
	Uuid     string      `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Topic    string      `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Metadata []*Metadata `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty"`
	Data     []byte      `protobuf:"bytes,4,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputReq) Descriptor deprecated 

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

Deprecated: Use OutputReq.ProtoReflect.Descriptor instead.

func (*OutputReq) GetData 

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

func (*OutputReq) GetMetadata 

func (x *OutputReq) GetMetadata() []*Metadata

func (*OutputReq) GetTopic 

func (x *OutputReq) GetTopic() string

func (*OutputReq) GetUuid 

func (x *OutputReq) GetUuid() string

func (*OutputReq) ProtoMessage 

func (*OutputReq) ProtoMessage()

func (*OutputReq) ProtoReflect 

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

func (*OutputReq) Reset 

func (x *OutputReq) Reset()

func (*OutputReq) String 

func (x *OutputReq) String() string

type OutputRes 

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

func (*OutputRes) Descriptor deprecated 

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

Deprecated: Use OutputRes.ProtoReflect.Descriptor instead.

func (*OutputRes) ProtoMessage 

func (*OutputRes) ProtoMessage()

func (*OutputRes) ProtoReflect 

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

func (*OutputRes) Reset 

func (x *OutputRes) Reset()

func (*OutputRes) String 

func (x *OutputRes) String() string

type PluginServiceClient 

type PluginServiceClient interface {
	Status(ctx context.Context, in *StatusReq, opts ...grpc.CallOption) (*StatusRes, error)
	Command(ctx context.Context, in *CommandReq, opts ...grpc.CallOption) (*CommandRes, error)
	Shutdown(ctx context.Context, in *ShutdownReq, opts ...grpc.CallOption) (*ShutdownRes, error)
	Output(ctx context.Context, in *OutputReq, opts ...grpc.CallOption) (*OutputRes, error)
	Input(ctx context.Context, in *InputReq, opts ...grpc.CallOption) (PluginService_InputClient, error)
}

PluginServiceClient is the client API for PluginService 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 NewPluginServiceClient 

func NewPluginServiceClient(cc grpc.ClientConnInterface) PluginServiceClient

type PluginServiceServer 

type PluginServiceServer interface {
	Status(context.Context, *StatusReq) (*StatusRes, error)
	Command(context.Context, *CommandReq) (*CommandRes, error)
	Shutdown(context.Context, *ShutdownReq) (*ShutdownRes, error)
	Output(context.Context, *OutputReq) (*OutputRes, error)
	Input(*InputReq, PluginService_InputServer) error
	// contains filtered or unexported methods
}

PluginServiceServer is the server API for PluginService service. All implementations must embed UnimplementedPluginServiceServer for forward compatibility

type PluginService_InputClient 

type PluginService_InputClient interface {
	Recv() (*InputRes, error)
	grpc.ClientStream
}

type PluginService_InputServer 

type PluginService_InputServer interface {
	Send(*InputRes) error
	grpc.ServerStream
}

type Result 

type Result int32
const (
	Result_RESULT_UNSPECIFIED Result = 0
	Result_RESULT_SUCCESS     Result = 1
	Result_RESULT_ERROR       Result = 2
	Result_RESULT_ASYNC       Result = 3
)

func (Result) Descriptor 

func (Result) Descriptor() protoreflect.EnumDescriptor

func (Result) Enum 

func (x Result) Enum() *Result

func (Result) EnumDescriptor deprecated 

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

Deprecated: Use Result.Descriptor instead.

func (Result) Number 

func (x Result) Number() protoreflect.EnumNumber

func (Result) String 

func (x Result) String() string

func (Result) Type 

func (Result) Type() protoreflect.EnumType

type ResultReq 

type ResultReq struct {
	PluginUuid string `protobuf:"bytes,1,opt,name=plugin_uuid,json=pluginUuid,proto3" json:"plugin_uuid,omitempty"`
	Uuid       string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Command    string `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"`
	Data       []byte `protobuf:"bytes,4,opt,name=data,proto3,oneof" json:"data,omitempty"`
	Result     Result `protobuf:"varint,5,opt,name=result,proto3,enum=eventrunner.plugin.v1.Result" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultReq) Descriptor deprecated 

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

Deprecated: Use ResultReq.ProtoReflect.Descriptor instead.

func (*ResultReq) GetCommand 

func (x *ResultReq) GetCommand() string

func (*ResultReq) GetData 

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

func (*ResultReq) GetPluginUuid 

func (x *ResultReq) GetPluginUuid() string

func (*ResultReq) GetResult 

func (x *ResultReq) GetResult() Result

func (*ResultReq) GetUuid 

func (x *ResultReq) GetUuid() string

func (*ResultReq) ProtoMessage 

func (*ResultReq) ProtoMessage()

func (*ResultReq) ProtoReflect 

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

func (*ResultReq) Reset 

func (x *ResultReq) Reset()

func (*ResultReq) String 

func (x *ResultReq) String() string

type ResultRes 

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

func (*ResultRes) Descriptor deprecated 

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

Deprecated: Use ResultRes.ProtoReflect.Descriptor instead.

func (*ResultRes) ProtoMessage 

func (*ResultRes) ProtoMessage()

func (*ResultRes) ProtoReflect 

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

func (*ResultRes) Reset 

func (x *ResultRes) Reset()

func (*ResultRes) String 

func (x *ResultRes) String() string

type ShutdownReq 

type ShutdownReq struct {
	Wait *string `protobuf:"bytes,1,opt,name=wait,proto3,oneof" json:"wait,omitempty"`
	// contains filtered or unexported fields
}

func (*ShutdownReq) Descriptor deprecated 

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

Deprecated: Use ShutdownReq.ProtoReflect.Descriptor instead.

func (*ShutdownReq) GetWait 

func (x *ShutdownReq) GetWait() string

func (*ShutdownReq) ProtoMessage 

func (*ShutdownReq) ProtoMessage()

func (*ShutdownReq) ProtoReflect 

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

func (*ShutdownReq) Reset 

func (x *ShutdownReq) Reset()

func (*ShutdownReq) String 

func (x *ShutdownReq) String() string

type ShutdownRes 

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

func (*ShutdownRes) Descriptor deprecated 

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

Deprecated: Use ShutdownRes.ProtoReflect.Descriptor instead.

func (*ShutdownRes) ProtoMessage 

func (*ShutdownRes) ProtoMessage()

func (*ShutdownRes) ProtoReflect 

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

func (*ShutdownRes) Reset 

func (x *ShutdownRes) Reset()

func (*ShutdownRes) String 

func (x *ShutdownRes) String() string

type Status 

type Status int32
const (
	Status_STATUS_UNSPECIFIED Status = 0
	Status_STATUS_STARTUP     Status = 1
	Status_STATUS_READY       Status = 3
	Status_STATUS_ERROR       Status = 4
	Status_STATUS_SHUTDOWN    Status = 5
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type StatusReq 

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

func (*StatusReq) Descriptor deprecated 

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

Deprecated: Use StatusReq.ProtoReflect.Descriptor instead.

func (*StatusReq) ProtoMessage 

func (*StatusReq) ProtoMessage()

func (*StatusReq) ProtoReflect 

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

func (*StatusReq) Reset 

func (x *StatusReq) Reset()

func (*StatusReq) String 

func (x *StatusReq) String() string

type StatusRes 

type StatusRes struct {
	Status Status  `protobuf:"varint,1,opt,name=status,proto3,enum=eventrunner.plugin.v1.Status" json:"status,omitempty"`
	Error  *string `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusRes) Descriptor deprecated 

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

Deprecated: Use StatusRes.ProtoReflect.Descriptor instead.

func (*StatusRes) GetError 

func (x *StatusRes) GetError() string

func (*StatusRes) GetStatus 

func (x *StatusRes) GetStatus() Status

func (*StatusRes) ProtoMessage 

func (*StatusRes) ProtoMessage()

func (*StatusRes) ProtoReflect 

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

func (*StatusRes) Reset 

func (x *StatusRes) Reset()

func (*StatusRes) String 

func (x *StatusRes) String() string

type UnimplementedAppServiceServer 

type UnimplementedAppServiceServer struct {
}

UnimplementedAppServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAppServiceServer) Result 

func (UnimplementedAppServiceServer) Result(context.Context, *ResultReq) (*ResultRes, error)

type UnimplementedPluginServiceServer 

type UnimplementedPluginServiceServer struct {
}

UnimplementedPluginServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginServiceServer) Command 

func (UnimplementedPluginServiceServer) Command(context.Context, *CommandReq) (*CommandRes, error)

func (UnimplementedPluginServiceServer) Input 

func (UnimplementedPluginServiceServer) Input(*InputReq, PluginService_InputServer) error

func (UnimplementedPluginServiceServer) Output 

func (UnimplementedPluginServiceServer) Output(context.Context, *OutputReq) (*OutputRes, error)

func (UnimplementedPluginServiceServer) Shutdown 

func (UnimplementedPluginServiceServer) Shutdown(context.Context, *ShutdownReq) (*ShutdownRes, error)

func (UnimplementedPluginServiceServer) Status 

func (UnimplementedPluginServiceServer) Status(context.Context, *StatusReq) (*StatusRes, error)

type UnsafeAppServiceServer 

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

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

type UnsafePluginServiceServer 

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

UnsafePluginServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginServiceServer 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.