commandpb

package
v0.5.2 Latest Latest
Warning

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

Go to latest
Published: Mar 28, 2026 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Stream_Subscribe_FullMethodName = "/omniview.sdk.command.v1.Stream/Subscribe"
	Stream_Run_FullMethodName       = "/omniview.sdk.command.v1.Stream/Run"
	Stream_Publish_FullMethodName   = "/omniview.sdk.command.v1.Stream/Publish"
)
View Source
const (
	Command_Call_FullMethodName = "/omniview.sdk.command.v1.Command/Call"
)

Variables

View Source
var (
	SubscribeStreamResponse_Status_name = map[int32]string{
		0: "OK",
		1: "NOT_FOUND",
		2: "PERMISSION_DENIED",
	}
	SubscribeStreamResponse_Status_value = map[string]int32{
		"OK":                0,
		"NOT_FOUND":         1,
		"PERMISSION_DENIED": 2,
	}
)

Enum value maps for SubscribeStreamResponse_Status.

View Source
var (
	PublishStreamResponse_Status_name = map[int32]string{
		0: "OK",
		1: "NOT_FOUND",
		2: "PERMISSION_DENIED",
	}
	PublishStreamResponse_Status_value = map[string]int32{
		"OK":                0,
		"NOT_FOUND":         1,
		"PERMISSION_DENIED": 2,
	}
)

Enum value maps for PublishStreamResponse_Status.

View Source
var Command_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "omniview.sdk.command.v1.Command",
	HandlerType: (*CommandServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Call",
			Handler:    _Command_Call_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/v1/command/command.proto",
}

Command_ServiceDesc is the grpc.ServiceDesc for Command 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_proto_v1_command_command_proto protoreflect.FileDescriptor
View Source
var Stream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "omniview.sdk.command.v1.Stream",
	HandlerType: (*StreamServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Subscribe",
			Handler:    _Stream_Subscribe_Handler,
		},
		{
			MethodName: "Publish",
			Handler:    _Stream_Publish_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Run",
			Handler:       _Stream_Run_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/v1/command/command.proto",
}

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

Functions

func RegisterCommandServer

func RegisterCommandServer(s grpc.ServiceRegistrar, srv CommandServer)

func RegisterStreamServer

func RegisterStreamServer(s grpc.ServiceRegistrar, srv StreamServer)

Types

type CallCommandRequest

type CallCommandRequest struct {
	PluginContext *PluginContext         `protobuf:"bytes,1,opt,name=plugin_context,json=pluginContext,proto3" json:"plugin_context,omitempty"`
	Path          string                 `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Method        string                 `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Url           string                 `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	Headers       map[string]*StringList `` /* 141-byte string literal not displayed */
	Body          []byte                 `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*CallCommandRequest) Descriptor deprecated

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

Deprecated: Use CallCommandRequest.ProtoReflect.Descriptor instead.

func (*CallCommandRequest) GetBody

func (x *CallCommandRequest) GetBody() []byte

func (*CallCommandRequest) GetHeaders

func (x *CallCommandRequest) GetHeaders() map[string]*StringList

func (*CallCommandRequest) GetMethod

func (x *CallCommandRequest) GetMethod() string

func (*CallCommandRequest) GetPath

func (x *CallCommandRequest) GetPath() string

func (*CallCommandRequest) GetPluginContext

func (x *CallCommandRequest) GetPluginContext() *PluginContext

func (*CallCommandRequest) GetUrl

func (x *CallCommandRequest) GetUrl() string

func (*CallCommandRequest) ProtoMessage

func (*CallCommandRequest) ProtoMessage()

func (*CallCommandRequest) ProtoReflect

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

func (*CallCommandRequest) Reset

func (x *CallCommandRequest) Reset()

func (*CallCommandRequest) String

func (x *CallCommandRequest) String() string

type CallCommandResponse

type CallCommandResponse struct {
	Code    int32                  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Headers map[string]*StringList `` /* 141-byte string literal not displayed */
	Body    []byte                 `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*CallCommandResponse) Descriptor deprecated

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

Deprecated: Use CallCommandResponse.ProtoReflect.Descriptor instead.

func (*CallCommandResponse) GetBody

func (x *CallCommandResponse) GetBody() []byte

func (*CallCommandResponse) GetCode

func (x *CallCommandResponse) GetCode() int32

func (*CallCommandResponse) GetHeaders

func (x *CallCommandResponse) GetHeaders() map[string]*StringList

func (*CallCommandResponse) ProtoMessage

func (*CallCommandResponse) ProtoMessage()

func (*CallCommandResponse) ProtoReflect

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

func (*CallCommandResponse) Reset

func (x *CallCommandResponse) Reset()

func (*CallCommandResponse) String

func (x *CallCommandResponse) String() string

type CommandClient

type CommandClient interface {
	Call(ctx context.Context, in *CallCommandRequest, opts ...grpc.CallOption) (*CallCommandResponse, error)
}

CommandClient is the client API for Command 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 NewCommandClient

func NewCommandClient(cc grpc.ClientConnInterface) CommandClient

type CommandServer

type CommandServer interface {
	Call(context.Context, *CallCommandRequest) (*CallCommandResponse, error)
}

CommandServer is the server API for Command service. All implementations should embed UnimplementedCommandServer for forward compatibility

type PluginContext

type PluginContext struct {

	// source plugin calling the API.
	PluginId string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	// settings for the plugin
	PluginSettings map[string]string `` /* 177-byte string literal not displayed */
	// global IDE settings
	GlobalSettings map[string]string `` /* 177-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PluginContext) Descriptor deprecated

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

Deprecated: Use PluginContext.ProtoReflect.Descriptor instead.

func (*PluginContext) GetGlobalSettings

func (x *PluginContext) GetGlobalSettings() map[string]string

func (*PluginContext) GetPluginId

func (x *PluginContext) GetPluginId() string

func (*PluginContext) GetPluginSettings

func (x *PluginContext) GetPluginSettings() map[string]string

func (*PluginContext) ProtoMessage

func (*PluginContext) ProtoMessage()

func (*PluginContext) ProtoReflect

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

func (*PluginContext) Reset

func (x *PluginContext) Reset()

func (*PluginContext) String

func (x *PluginContext) String() string

type PublishStreamRequest

type PublishStreamRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=plugin_context,json=pluginContext,proto3" json:"plugin_context,omitempty"`
	// path part of a channel.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// data that user wants to publish into a stream
	// (only JSON-encoded at the moment).
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishStreamRequest) Descriptor deprecated

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

Deprecated: Use PublishStreamRequest.ProtoReflect.Descriptor instead.

func (*PublishStreamRequest) GetData

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

func (*PublishStreamRequest) GetPath

func (x *PublishStreamRequest) GetPath() string

func (*PublishStreamRequest) GetPluginContext

func (x *PublishStreamRequest) GetPluginContext() *PluginContext

func (*PublishStreamRequest) ProtoMessage

func (*PublishStreamRequest) ProtoMessage()

func (*PublishStreamRequest) ProtoReflect

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

func (*PublishStreamRequest) Reset

func (x *PublishStreamRequest) Reset()

func (*PublishStreamRequest) String

func (x *PublishStreamRequest) String() string

type PublishStreamResponse

type PublishStreamResponse struct {
	Status PublishStreamResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=omniview.sdk.command.v1.PublishStreamResponse_Status" json:"status,omitempty"`
	Data   []byte                       `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishStreamResponse) Descriptor deprecated

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

Deprecated: Use PublishStreamResponse.ProtoReflect.Descriptor instead.

func (*PublishStreamResponse) GetData

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

func (*PublishStreamResponse) GetStatus

func (*PublishStreamResponse) ProtoMessage

func (*PublishStreamResponse) ProtoMessage()

func (*PublishStreamResponse) ProtoReflect

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

func (*PublishStreamResponse) Reset

func (x *PublishStreamResponse) Reset()

func (*PublishStreamResponse) String

func (x *PublishStreamResponse) String() string

type PublishStreamResponse_Status

type PublishStreamResponse_Status int32
const (
	PublishStreamResponse_OK                PublishStreamResponse_Status = 0
	PublishStreamResponse_NOT_FOUND         PublishStreamResponse_Status = 1
	PublishStreamResponse_PERMISSION_DENIED PublishStreamResponse_Status = 2
)

func (PublishStreamResponse_Status) Descriptor

func (PublishStreamResponse_Status) Enum

func (PublishStreamResponse_Status) EnumDescriptor deprecated

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

Deprecated: Use PublishStreamResponse_Status.Descriptor instead.

func (PublishStreamResponse_Status) Number

func (PublishStreamResponse_Status) String

func (PublishStreamResponse_Status) Type

type RunStreamRequest

type RunStreamRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=plugin_context,json=pluginContext,proto3" json:"plugin_context,omitempty"`
	Path          string         `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*RunStreamRequest) Descriptor deprecated

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

Deprecated: Use RunStreamRequest.ProtoReflect.Descriptor instead.

func (*RunStreamRequest) GetPath

func (x *RunStreamRequest) GetPath() string

func (*RunStreamRequest) GetPluginContext

func (x *RunStreamRequest) GetPluginContext() *PluginContext

func (*RunStreamRequest) ProtoMessage

func (*RunStreamRequest) ProtoMessage()

func (*RunStreamRequest) ProtoReflect

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

func (*RunStreamRequest) Reset

func (x *RunStreamRequest) Reset()

func (*RunStreamRequest) String

func (x *RunStreamRequest) String() string

type StreamClient

StreamClient is the client API for Stream 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 NewStreamClient

func NewStreamClient(cc grpc.ClientConnInterface) StreamClient

type StreamPacket

type StreamPacket struct {

	// JSON-encoded data to publish into a channel.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPacket) Descriptor deprecated

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

Deprecated: Use StreamPacket.ProtoReflect.Descriptor instead.

func (*StreamPacket) GetData

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

func (*StreamPacket) ProtoMessage

func (*StreamPacket) ProtoMessage()

func (*StreamPacket) ProtoReflect

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

func (*StreamPacket) Reset

func (x *StreamPacket) Reset()

func (*StreamPacket) String

func (x *StreamPacket) String() string

type StreamServer

StreamServer is the server API for Stream service. All implementations should embed UnimplementedStreamServer for forward compatibility

type Stream_RunClient

type Stream_RunClient interface {
	Recv() (*StreamPacket, error)
	grpc.ClientStream
}

type Stream_RunServer

type Stream_RunServer interface {
	Send(*StreamPacket) error
	grpc.ServerStream
}

type StringList

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

func (*StringList) Descriptor deprecated

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

Deprecated: Use StringList.ProtoReflect.Descriptor instead.

func (*StringList) GetValues

func (x *StringList) GetValues() []string

func (*StringList) ProtoMessage

func (*StringList) ProtoMessage()

func (*StringList) ProtoReflect

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

func (*StringList) Reset

func (x *StringList) Reset()

func (*StringList) String

func (x *StringList) String() string

type SubscribeStreamRequest

type SubscribeStreamRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=plugin_context,json=pluginContext,proto3" json:"plugin_context,omitempty"`
	// path part of channel.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamRequest) Descriptor deprecated

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

Deprecated: Use SubscribeStreamRequest.ProtoReflect.Descriptor instead.

func (*SubscribeStreamRequest) GetPath

func (x *SubscribeStreamRequest) GetPath() string

func (*SubscribeStreamRequest) GetPluginContext

func (x *SubscribeStreamRequest) GetPluginContext() *PluginContext

func (*SubscribeStreamRequest) ProtoMessage

func (*SubscribeStreamRequest) ProtoMessage()

func (*SubscribeStreamRequest) ProtoReflect

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

func (*SubscribeStreamRequest) Reset

func (x *SubscribeStreamRequest) Reset()

func (*SubscribeStreamRequest) String

func (x *SubscribeStreamRequest) String() string

type SubscribeStreamResponse

type SubscribeStreamResponse struct {

	// status of subscribe response.
	Status SubscribeStreamResponse_Status `` /* 126-byte string literal not displayed */
	// JSON-encoded data to return to a client in a successful
	// subscription result.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamResponse) Descriptor deprecated

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

Deprecated: Use SubscribeStreamResponse.ProtoReflect.Descriptor instead.

func (*SubscribeStreamResponse) GetData

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

func (*SubscribeStreamResponse) GetStatus

func (*SubscribeStreamResponse) ProtoMessage

func (*SubscribeStreamResponse) ProtoMessage()

func (*SubscribeStreamResponse) ProtoReflect

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

func (*SubscribeStreamResponse) Reset

func (x *SubscribeStreamResponse) Reset()

func (*SubscribeStreamResponse) String

func (x *SubscribeStreamResponse) String() string

type SubscribeStreamResponse_Status

type SubscribeStreamResponse_Status int32
const (
	SubscribeStreamResponse_OK                SubscribeStreamResponse_Status = 0
	SubscribeStreamResponse_NOT_FOUND         SubscribeStreamResponse_Status = 1
	SubscribeStreamResponse_PERMISSION_DENIED SubscribeStreamResponse_Status = 2
)

func (SubscribeStreamResponse_Status) Descriptor

func (SubscribeStreamResponse_Status) Enum

func (SubscribeStreamResponse_Status) EnumDescriptor deprecated

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

Deprecated: Use SubscribeStreamResponse_Status.Descriptor instead.

func (SubscribeStreamResponse_Status) Number

func (SubscribeStreamResponse_Status) String

func (SubscribeStreamResponse_Status) Type

type UnimplementedCommandServer

type UnimplementedCommandServer struct {
}

UnimplementedCommandServer should be embedded to have forward compatible implementations.

func (UnimplementedCommandServer) Call

type UnimplementedStreamServer

type UnimplementedStreamServer struct {
}

UnimplementedStreamServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamServer) Publish

func (UnimplementedStreamServer) Run

type UnsafeCommandServer

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

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

type UnsafeStreamServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL