Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterCommandServer(s grpc.ServiceRegistrar, srv CommandServer)
- func RegisterStreamServer(s grpc.ServiceRegistrar, srv StreamServer)
- type CallCommandRequest
- func (*CallCommandRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CallCommandRequest) GetBody() []byte
- func (x *CallCommandRequest) GetHeaders() map[string]*StringList
- func (x *CallCommandRequest) GetMethod() string
- func (x *CallCommandRequest) GetPath() string
- func (x *CallCommandRequest) GetPluginContext() *PluginContext
- func (x *CallCommandRequest) GetUrl() string
- func (*CallCommandRequest) ProtoMessage()
- func (x *CallCommandRequest) ProtoReflect() protoreflect.Message
- func (x *CallCommandRequest) Reset()
- func (x *CallCommandRequest) String() string
- type CallCommandResponse
- func (*CallCommandResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CallCommandResponse) GetBody() []byte
- func (x *CallCommandResponse) GetCode() int32
- func (x *CallCommandResponse) GetHeaders() map[string]*StringList
- func (*CallCommandResponse) ProtoMessage()
- func (x *CallCommandResponse) ProtoReflect() protoreflect.Message
- func (x *CallCommandResponse) Reset()
- func (x *CallCommandResponse) String() string
- type CommandClient
- type CommandServer
- type PluginContext
- func (*PluginContext) Descriptor() ([]byte, []int)deprecated
- func (x *PluginContext) GetGlobalSettings() map[string]string
- func (x *PluginContext) GetPluginId() string
- func (x *PluginContext) GetPluginSettings() map[string]string
- func (*PluginContext) ProtoMessage()
- func (x *PluginContext) ProtoReflect() protoreflect.Message
- func (x *PluginContext) Reset()
- func (x *PluginContext) String() string
- type PublishStreamRequest
- func (*PublishStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishStreamRequest) GetData() []byte
- func (x *PublishStreamRequest) GetPath() string
- func (x *PublishStreamRequest) GetPluginContext() *PluginContext
- func (*PublishStreamRequest) ProtoMessage()
- func (x *PublishStreamRequest) ProtoReflect() protoreflect.Message
- func (x *PublishStreamRequest) Reset()
- func (x *PublishStreamRequest) String() string
- type PublishStreamResponse
- func (*PublishStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PublishStreamResponse) GetData() []byte
- func (x *PublishStreamResponse) GetStatus() PublishStreamResponse_Status
- func (*PublishStreamResponse) ProtoMessage()
- func (x *PublishStreamResponse) ProtoReflect() protoreflect.Message
- func (x *PublishStreamResponse) Reset()
- func (x *PublishStreamResponse) String() string
- type PublishStreamResponse_Status
- func (PublishStreamResponse_Status) Descriptor() protoreflect.EnumDescriptor
- func (x PublishStreamResponse_Status) Enum() *PublishStreamResponse_Status
- func (PublishStreamResponse_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x PublishStreamResponse_Status) Number() protoreflect.EnumNumber
- func (x PublishStreamResponse_Status) String() string
- func (PublishStreamResponse_Status) Type() protoreflect.EnumType
- type RunStreamRequest
- func (*RunStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RunStreamRequest) GetPath() string
- func (x *RunStreamRequest) GetPluginContext() *PluginContext
- func (*RunStreamRequest) ProtoMessage()
- func (x *RunStreamRequest) ProtoReflect() protoreflect.Message
- func (x *RunStreamRequest) Reset()
- func (x *RunStreamRequest) String() string
- type StreamClient
- type StreamPacket
- type StreamServer
- type Stream_RunClient
- type Stream_RunServer
- type StringList
- type SubscribeStreamRequest
- func (*SubscribeStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeStreamRequest) GetPath() string
- func (x *SubscribeStreamRequest) GetPluginContext() *PluginContext
- func (*SubscribeStreamRequest) ProtoMessage()
- func (x *SubscribeStreamRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeStreamRequest) Reset()
- func (x *SubscribeStreamRequest) String() string
- type SubscribeStreamResponse
- func (*SubscribeStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeStreamResponse) GetData() []byte
- func (x *SubscribeStreamResponse) GetStatus() SubscribeStreamResponse_Status
- func (*SubscribeStreamResponse) ProtoMessage()
- func (x *SubscribeStreamResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeStreamResponse) Reset()
- func (x *SubscribeStreamResponse) String() string
- type SubscribeStreamResponse_Status
- func (SubscribeStreamResponse_Status) Descriptor() protoreflect.EnumDescriptor
- func (x SubscribeStreamResponse_Status) Enum() *SubscribeStreamResponse_Status
- func (SubscribeStreamResponse_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x SubscribeStreamResponse_Status) Number() protoreflect.EnumNumber
- func (x SubscribeStreamResponse_Status) String() string
- func (SubscribeStreamResponse_Status) Type() protoreflect.EnumType
- type UnimplementedCommandServer
- type UnimplementedStreamServer
- func (UnimplementedStreamServer) Publish(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error)
- func (UnimplementedStreamServer) Run(*RunStreamRequest, Stream_RunServer) error
- func (UnimplementedStreamServer) Subscribe(context.Context, *SubscribeStreamRequest) (*SubscribeStreamResponse, error)
- type UnsafeCommandServer
- type UnsafeStreamServer
Constants ¶
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" )
const (
Command_Call_FullMethodName = "/omniview.sdk.command.v1.Command/Call"
)
Variables ¶
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.
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.
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)
var File_proto_v1_command_command_proto protoreflect.FileDescriptor
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 (x *PublishStreamResponse) GetStatus() PublishStreamResponse_Status
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) Descriptor() protoreflect.EnumDescriptor
func (PublishStreamResponse_Status) Enum ¶
func (x PublishStreamResponse_Status) Enum() *PublishStreamResponse_Status
func (PublishStreamResponse_Status) EnumDescriptor
deprecated
func (PublishStreamResponse_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use PublishStreamResponse_Status.Descriptor instead.
func (PublishStreamResponse_Status) Number ¶
func (x PublishStreamResponse_Status) Number() protoreflect.EnumNumber
func (PublishStreamResponse_Status) String ¶
func (x PublishStreamResponse_Status) String() string
func (PublishStreamResponse_Status) Type ¶
func (PublishStreamResponse_Status) Type() protoreflect.EnumType
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 ¶
type StreamClient interface {
Subscribe(ctx context.Context, in *SubscribeStreamRequest, opts ...grpc.CallOption) (*SubscribeStreamResponse, error)
Run(ctx context.Context, in *RunStreamRequest, opts ...grpc.CallOption) (Stream_RunClient, error)
Publish(ctx context.Context, in *PublishStreamRequest, opts ...grpc.CallOption) (*PublishStreamResponse, error)
}
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 ¶
type StreamServer interface {
Subscribe(context.Context, *SubscribeStreamRequest) (*SubscribeStreamResponse, error)
Run(*RunStreamRequest, Stream_RunServer) error
Publish(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error)
}
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 (x *SubscribeStreamResponse) GetStatus() SubscribeStreamResponse_Status
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) Descriptor() protoreflect.EnumDescriptor
func (SubscribeStreamResponse_Status) Enum ¶
func (x SubscribeStreamResponse_Status) Enum() *SubscribeStreamResponse_Status
func (SubscribeStreamResponse_Status) EnumDescriptor
deprecated
func (SubscribeStreamResponse_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use SubscribeStreamResponse_Status.Descriptor instead.
func (SubscribeStreamResponse_Status) Number ¶
func (x SubscribeStreamResponse_Status) Number() protoreflect.EnumNumber
func (SubscribeStreamResponse_Status) String ¶
func (x SubscribeStreamResponse_Status) String() string
func (SubscribeStreamResponse_Status) Type ¶
func (SubscribeStreamResponse_Status) Type() protoreflect.EnumType
type UnimplementedCommandServer ¶
type UnimplementedCommandServer struct {
}
UnimplementedCommandServer should be embedded to have forward compatible implementations.
func (UnimplementedCommandServer) Call ¶
func (UnimplementedCommandServer) Call(context.Context, *CallCommandRequest) (*CallCommandResponse, error)
type UnimplementedStreamServer ¶
type UnimplementedStreamServer struct {
}
UnimplementedStreamServer should be embedded to have forward compatible implementations.
func (UnimplementedStreamServer) Publish ¶
func (UnimplementedStreamServer) Publish(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error)
func (UnimplementedStreamServer) Run ¶
func (UnimplementedStreamServer) Run(*RunStreamRequest, Stream_RunServer) error
func (UnimplementedStreamServer) Subscribe ¶
func (UnimplementedStreamServer) Subscribe(context.Context, *SubscribeStreamRequest) (*SubscribeStreamResponse, error)
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.