component

package
v1.1.15 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2019 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var StreamFrameKind_name = map[int32]string{
	0: "STREAM_FRAME_KIND_UNKNOWN",
	1: "STREAM_FRAME_KIND_SYSTEM",
	2: "STREAM_FRAME_KIND_USER",
}
View Source 
var StreamFrameKind_value = map[string]int32{
	"STREAM_FRAME_KIND_UNKNOWN": 0,
	"STREAM_FRAME_KIND_SYSTEM":  1,
	"STREAM_FRAME_KIND_USER":    2,
}

Functions

func RegisterModuleServiceServer 

func RegisterModuleServiceServer(s *grpc.Server, srv ModuleServiceServer)

Types

type DownStreamFrame added in v1.0.0 

type DownStreamFrame struct {
	Kind StreamFrameKind `protobuf:"varint,1,opt,name=kind,proto3,enum=ai.metathings.component.StreamFrameKind" json:"kind,omitempty"`
	// Types that are valid to be assigned to Union:
	//	*DownStreamFrame_UnaryCall
	//	*DownStreamFrame_StreamCall
	Union                isDownStreamFrame_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*DownStreamFrame) Descriptor added in v1.0.0 

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

func (*DownStreamFrame) GetKind added in v1.0.0 

func (m *DownStreamFrame) GetKind() StreamFrameKind

func (*DownStreamFrame) GetStreamCall added in v1.0.0 

func (m *DownStreamFrame) GetStreamCall() *OpStreamCallValue

func (*DownStreamFrame) GetUnaryCall added in v1.0.0 

func (m *DownStreamFrame) GetUnaryCall() *OpUnaryCallValue

func (*DownStreamFrame) GetUnion added in v1.0.0 

func (m *DownStreamFrame) GetUnion() isDownStreamFrame_Union

func (*DownStreamFrame) ProtoMessage added in v1.0.0 

func (*DownStreamFrame) ProtoMessage()

func (*DownStreamFrame) Reset added in v1.0.0 

func (m *DownStreamFrame) Reset()

func (*DownStreamFrame) String added in v1.0.0 

func (m *DownStreamFrame) String() string

func (*DownStreamFrame) Validate added in v1.0.0 

func (this *DownStreamFrame) Validate() error

func (*DownStreamFrame) XXX_DiscardUnknown added in v1.0.0 

func (m *DownStreamFrame) XXX_DiscardUnknown()

func (*DownStreamFrame) XXX_Marshal added in v1.0.0 

func (m *DownStreamFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownStreamFrame) XXX_Merge added in v1.0.0 

func (m *DownStreamFrame) XXX_Merge(src proto.Message)

func (*DownStreamFrame) XXX_OneofWrappers added in v1.0.0 

func (*DownStreamFrame) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*DownStreamFrame) XXX_Size added in v1.0.0 

func (m *DownStreamFrame) XXX_Size() int

func (*DownStreamFrame) XXX_Unmarshal added in v1.0.0 

func (m *DownStreamFrame) XXX_Unmarshal(b []byte) error

type DownStreamFrame_StreamCall added in v1.0.0 

type DownStreamFrame_StreamCall struct {
	StreamCall *OpStreamCallValue `protobuf:"bytes,3,opt,name=stream_call,json=streamCall,proto3,oneof"`
}

type DownStreamFrame_UnaryCall added in v1.0.0 

type DownStreamFrame_UnaryCall struct {
	UnaryCall *OpUnaryCallValue `protobuf:"bytes,2,opt,name=unary_call,json=unaryCall,proto3,oneof"`
}

type ErrorValue added in v1.0.0 

type ErrorValue struct {
	Code                 int64    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ErrorValue) Descriptor added in v1.0.0 

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

func (*ErrorValue) GetCode added in v1.0.0 

func (m *ErrorValue) GetCode() int64

func (*ErrorValue) GetMessage added in v1.0.0 

func (m *ErrorValue) GetMessage() string

func (*ErrorValue) ProtoMessage added in v1.0.0 

func (*ErrorValue) ProtoMessage()

func (*ErrorValue) Reset added in v1.0.0 

func (m *ErrorValue) Reset()

func (*ErrorValue) String added in v1.0.0 

func (m *ErrorValue) String() string

func (*ErrorValue) Validate added in v1.0.0 

func (this *ErrorValue) Validate() error

func (*ErrorValue) XXX_DiscardUnknown added in v1.0.0 

func (m *ErrorValue) XXX_DiscardUnknown()

func (*ErrorValue) XXX_Marshal added in v1.0.0 

func (m *ErrorValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ErrorValue) XXX_Merge added in v1.0.0 

func (m *ErrorValue) XXX_Merge(src proto.Message)

func (*ErrorValue) XXX_Size added in v1.0.0 

func (m *ErrorValue) XXX_Size() int

func (*ErrorValue) XXX_Unmarshal added in v1.0.0 

func (m *ErrorValue) XXX_Unmarshal(b []byte) error

type ModuleServiceClient 

type ModuleServiceClient interface {
	UnaryCall(ctx context.Context, in *UnaryCallRequest, opts ...grpc.CallOption) (*UnaryCallResponse, error)
	StreamCall(ctx context.Context, opts ...grpc.CallOption) (ModuleService_StreamCallClient, error)
}

ModuleServiceClient is the client API for ModuleService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewModuleServiceClient 

func NewModuleServiceClient(cc *grpc.ClientConn) ModuleServiceClient

type ModuleServiceServer 

type ModuleServiceServer interface {
	UnaryCall(context.Context, *UnaryCallRequest) (*UnaryCallResponse, error)
	StreamCall(ModuleService_StreamCallServer) error
}

ModuleServiceServer is the server API for ModuleService service.

type ModuleService_StreamCallClient 

type ModuleService_StreamCallClient interface {
	Send(*StreamCallRequest) error
	Recv() (*StreamCallResponse, error)
	grpc.ClientStream
}

type ModuleService_StreamCallServer 

type ModuleService_StreamCallServer interface {
	Send(*StreamCallResponse) error
	Recv() (*StreamCallRequest, error)
	grpc.ServerStream
}

type OpStreamCallAck added in v1.0.0 

type OpStreamCallAck struct {
	Value                *wrappers.Int64Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*OpStreamCallAck) Descriptor added in v1.0.0 

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

func (*OpStreamCallAck) GetValue added in v1.0.0 

func (m *OpStreamCallAck) GetValue() *wrappers.Int64Value

func (*OpStreamCallAck) ProtoMessage added in v1.0.0 

func (*OpStreamCallAck) ProtoMessage()

func (*OpStreamCallAck) Reset added in v1.0.0 

func (m *OpStreamCallAck) Reset()

func (*OpStreamCallAck) String added in v1.0.0 

func (m *OpStreamCallAck) String() string

func (*OpStreamCallAck) Validate added in v1.0.0 

func (this *OpStreamCallAck) Validate() error

func (*OpStreamCallAck) XXX_DiscardUnknown added in v1.0.0 

func (m *OpStreamCallAck) XXX_DiscardUnknown()

func (*OpStreamCallAck) XXX_Marshal added in v1.0.0 

func (m *OpStreamCallAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpStreamCallAck) XXX_Merge added in v1.0.0 

func (m *OpStreamCallAck) XXX_Merge(src proto.Message)

func (*OpStreamCallAck) XXX_Size added in v1.0.0 

func (m *OpStreamCallAck) XXX_Size() int

func (*OpStreamCallAck) XXX_Unmarshal added in v1.0.0 

func (m *OpStreamCallAck) XXX_Unmarshal(b []byte) error

type OpStreamCallConfig added in v1.0.0 

type OpStreamCallConfig struct {
	Session              *wrappers.Int64Value  `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Method               *wrappers.StringValue `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Ack                  *wrappers.Int64Value  `protobuf:"bytes,3,opt,name=ack,proto3" json:"ack,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpStreamCallConfig) Descriptor added in v1.0.0 

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

func (*OpStreamCallConfig) GetAck added in v1.0.0 

func (m *OpStreamCallConfig) GetAck() *wrappers.Int64Value

func (*OpStreamCallConfig) GetMethod added in v1.0.0 

func (m *OpStreamCallConfig) GetMethod() *wrappers.StringValue

func (*OpStreamCallConfig) GetSession added in v1.0.0 

func (m *OpStreamCallConfig) GetSession() *wrappers.Int64Value

func (*OpStreamCallConfig) ProtoMessage added in v1.0.0 

func (*OpStreamCallConfig) ProtoMessage()

func (*OpStreamCallConfig) Reset added in v1.0.0 

func (m *OpStreamCallConfig) Reset()

func (*OpStreamCallConfig) String added in v1.0.0 

func (m *OpStreamCallConfig) String() string

func (*OpStreamCallConfig) Validate added in v1.0.0 

func (this *OpStreamCallConfig) Validate() error

func (*OpStreamCallConfig) XXX_DiscardUnknown added in v1.0.0 

func (m *OpStreamCallConfig) XXX_DiscardUnknown()

func (*OpStreamCallConfig) XXX_Marshal added in v1.0.0 

func (m *OpStreamCallConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpStreamCallConfig) XXX_Merge added in v1.0.0 

func (m *OpStreamCallConfig) XXX_Merge(src proto.Message)

func (*OpStreamCallConfig) XXX_Size added in v1.0.0 

func (m *OpStreamCallConfig) XXX_Size() int

func (*OpStreamCallConfig) XXX_Unmarshal added in v1.0.0 

func (m *OpStreamCallConfig) XXX_Unmarshal(b []byte) error

type OpStreamCallExit added in v1.0.0 

type OpStreamCallExit struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OpStreamCallExit) Descriptor added in v1.0.0 

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

func (*OpStreamCallExit) ProtoMessage added in v1.0.0 

func (*OpStreamCallExit) ProtoMessage()

func (*OpStreamCallExit) Reset added in v1.0.0 

func (m *OpStreamCallExit) Reset()

func (*OpStreamCallExit) String added in v1.0.0 

func (m *OpStreamCallExit) String() string

func (*OpStreamCallExit) Validate added in v1.0.0 

func (this *OpStreamCallExit) Validate() error

func (*OpStreamCallExit) XXX_DiscardUnknown added in v1.0.0 

func (m *OpStreamCallExit) XXX_DiscardUnknown()

func (*OpStreamCallExit) XXX_Marshal added in v1.0.0 

func (m *OpStreamCallExit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpStreamCallExit) XXX_Merge added in v1.0.0 

func (m *OpStreamCallExit) XXX_Merge(src proto.Message)

func (*OpStreamCallExit) XXX_Size added in v1.0.0 

func (m *OpStreamCallExit) XXX_Size() int

func (*OpStreamCallExit) XXX_Unmarshal added in v1.0.0 

func (m *OpStreamCallExit) XXX_Unmarshal(b []byte) error

type OpStreamCallValue added in v1.0.0 

type OpStreamCallValue struct {
	// Types that are valid to be assigned to Union:
	//	*OpStreamCallValue_Value
	//	*OpStreamCallValue_Config
	//	*OpStreamCallValue_Ack
	//	*OpStreamCallValue_Exit
	Union                isOpStreamCallValue_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*OpStreamCallValue) Descriptor added in v1.0.0 

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

func (*OpStreamCallValue) GetAck added in v1.0.0 

func (m *OpStreamCallValue) GetAck() *OpStreamCallAck

func (*OpStreamCallValue) GetConfig added in v1.0.0 

func (m *OpStreamCallValue) GetConfig() *OpStreamCallConfig

func (*OpStreamCallValue) GetExit added in v1.0.0 

func (m *OpStreamCallValue) GetExit() *OpStreamCallExit

func (*OpStreamCallValue) GetUnion added in v1.0.0 

func (m *OpStreamCallValue) GetUnion() isOpStreamCallValue_Union

func (*OpStreamCallValue) GetValue added in v1.0.0 

func (m *OpStreamCallValue) GetValue() *any.Any

func (*OpStreamCallValue) ProtoMessage added in v1.0.0 

func (*OpStreamCallValue) ProtoMessage()

func (*OpStreamCallValue) Reset added in v1.0.0 

func (m *OpStreamCallValue) Reset()

func (*OpStreamCallValue) String added in v1.0.0 

func (m *OpStreamCallValue) String() string

func (*OpStreamCallValue) Validate added in v1.0.0 

func (this *OpStreamCallValue) Validate() error

func (*OpStreamCallValue) XXX_DiscardUnknown added in v1.0.0 

func (m *OpStreamCallValue) XXX_DiscardUnknown()

func (*OpStreamCallValue) XXX_Marshal added in v1.0.0 

func (m *OpStreamCallValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpStreamCallValue) XXX_Merge added in v1.0.0 

func (m *OpStreamCallValue) XXX_Merge(src proto.Message)

func (*OpStreamCallValue) XXX_OneofWrappers added in v1.0.0 

func (*OpStreamCallValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*OpStreamCallValue) XXX_Size added in v1.0.0 

func (m *OpStreamCallValue) XXX_Size() int

func (*OpStreamCallValue) XXX_Unmarshal added in v1.0.0 

func (m *OpStreamCallValue) XXX_Unmarshal(b []byte) error

type OpStreamCallValue_Ack added in v1.0.0 

type OpStreamCallValue_Ack struct {
	Ack *OpStreamCallAck `protobuf:"bytes,3,opt,name=ack,proto3,oneof"`
}

type OpStreamCallValue_Config added in v1.0.0 

type OpStreamCallValue_Config struct {
	Config *OpStreamCallConfig `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type OpStreamCallValue_Exit added in v1.0.0 

type OpStreamCallValue_Exit struct {
	Exit *OpStreamCallExit `protobuf:"bytes,4,opt,name=exit,proto3,oneof"`
}

type OpStreamCallValue_Value added in v1.0.0 

type OpStreamCallValue_Value struct {
	Value *any.Any `protobuf:"bytes,1,opt,name=value,proto3,oneof"`
}

type OpUnaryCallValue added in v1.0.0 

type OpUnaryCallValue struct {
	Session              *wrappers.Int64Value  `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Method               *wrappers.StringValue `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Value                *any.Any              `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpUnaryCallValue) Descriptor added in v1.0.0 

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

func (*OpUnaryCallValue) GetMethod added in v1.0.0 

func (m *OpUnaryCallValue) GetMethod() *wrappers.StringValue

func (*OpUnaryCallValue) GetSession added in v1.0.0 

func (m *OpUnaryCallValue) GetSession() *wrappers.Int64Value

func (*OpUnaryCallValue) GetValue added in v1.0.0 

func (m *OpUnaryCallValue) GetValue() *any.Any

func (*OpUnaryCallValue) ProtoMessage added in v1.0.0 

func (*OpUnaryCallValue) ProtoMessage()

func (*OpUnaryCallValue) Reset added in v1.0.0 

func (m *OpUnaryCallValue) Reset()

func (*OpUnaryCallValue) String added in v1.0.0 

func (m *OpUnaryCallValue) String() string

func (*OpUnaryCallValue) Validate added in v1.0.0 

func (this *OpUnaryCallValue) Validate() error

func (*OpUnaryCallValue) XXX_DiscardUnknown added in v1.0.0 

func (m *OpUnaryCallValue) XXX_DiscardUnknown()

func (*OpUnaryCallValue) XXX_Marshal added in v1.0.0 

func (m *OpUnaryCallValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpUnaryCallValue) XXX_Merge added in v1.0.0 

func (m *OpUnaryCallValue) XXX_Merge(src proto.Message)

func (*OpUnaryCallValue) XXX_Size added in v1.0.0 

func (m *OpUnaryCallValue) XXX_Size() int

func (*OpUnaryCallValue) XXX_Unmarshal added in v1.0.0 

func (m *OpUnaryCallValue) XXX_Unmarshal(b []byte) error

type StreamCallAck added in v1.0.0 

type StreamCallAck struct {
	Value                int64    `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCallAck) Descriptor added in v1.0.0 

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

func (*StreamCallAck) GetValue added in v1.0.0 

func (m *StreamCallAck) GetValue() int64

func (*StreamCallAck) ProtoMessage added in v1.0.0 

func (*StreamCallAck) ProtoMessage()

func (*StreamCallAck) Reset added in v1.0.0 

func (m *StreamCallAck) Reset()

func (*StreamCallAck) String added in v1.0.0 

func (m *StreamCallAck) String() string

func (*StreamCallAck) Validate added in v1.0.0 

func (this *StreamCallAck) Validate() error

func (*StreamCallAck) XXX_DiscardUnknown added in v1.0.0 

func (m *StreamCallAck) XXX_DiscardUnknown()

func (*StreamCallAck) XXX_Marshal added in v1.0.0 

func (m *StreamCallAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCallAck) XXX_Merge added in v1.0.0 

func (m *StreamCallAck) XXX_Merge(src proto.Message)

func (*StreamCallAck) XXX_Size added in v1.0.0 

func (m *StreamCallAck) XXX_Size() int

func (*StreamCallAck) XXX_Unmarshal added in v1.0.0 

func (m *StreamCallAck) XXX_Unmarshal(b []byte) error

type StreamCallConfig added in v1.0.0 

type StreamCallConfig struct {
	Session              int64    `protobuf:"varint,1,opt,name=session,proto3" json:"session,omitempty"`
	Method               string   `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Ack                  int64    `protobuf:"varint,3,opt,name=ack,proto3" json:"ack,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCallConfig) Descriptor added in v1.0.0 

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

func (*StreamCallConfig) GetAck added in v1.0.0 

func (m *StreamCallConfig) GetAck() int64

func (*StreamCallConfig) GetMethod added in v1.0.0 

func (m *StreamCallConfig) GetMethod() string

func (*StreamCallConfig) GetSession added in v1.0.0 

func (m *StreamCallConfig) GetSession() int64

func (*StreamCallConfig) ProtoMessage added in v1.0.0 

func (*StreamCallConfig) ProtoMessage()

func (*StreamCallConfig) Reset added in v1.0.0 

func (m *StreamCallConfig) Reset()

func (*StreamCallConfig) String added in v1.0.0 

func (m *StreamCallConfig) String() string

func (*StreamCallConfig) Validate added in v1.0.0 

func (this *StreamCallConfig) Validate() error

func (*StreamCallConfig) XXX_DiscardUnknown added in v1.0.0 

func (m *StreamCallConfig) XXX_DiscardUnknown()

func (*StreamCallConfig) XXX_Marshal added in v1.0.0 

func (m *StreamCallConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCallConfig) XXX_Merge added in v1.0.0 

func (m *StreamCallConfig) XXX_Merge(src proto.Message)

func (*StreamCallConfig) XXX_Size added in v1.0.0 

func (m *StreamCallConfig) XXX_Size() int

func (*StreamCallConfig) XXX_Unmarshal added in v1.0.0 

func (m *StreamCallConfig) XXX_Unmarshal(b []byte) error

type StreamCallConfigRequest 

type StreamCallConfigRequest struct {
	Method               *wrappers.StringValue `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*StreamCallConfigRequest) Descriptor 

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

func (*StreamCallConfigRequest) GetMethod 

func (m *StreamCallConfigRequest) GetMethod() *wrappers.StringValue

func (*StreamCallConfigRequest) ProtoMessage 

func (*StreamCallConfigRequest) ProtoMessage()

func (*StreamCallConfigRequest) Reset 

func (m *StreamCallConfigRequest) Reset()

func (*StreamCallConfigRequest) String 

func (m *StreamCallConfigRequest) String() string

func (*StreamCallConfigRequest) Validate 

func (this *StreamCallConfigRequest) Validate() error

func (*StreamCallConfigRequest) XXX_DiscardUnknown 

func (m *StreamCallConfigRequest) XXX_DiscardUnknown()

func (*StreamCallConfigRequest) XXX_Marshal 

func (m *StreamCallConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCallConfigRequest) XXX_Merge 

func (m *StreamCallConfigRequest) XXX_Merge(src proto.Message)

func (*StreamCallConfigRequest) XXX_Size 

func (m *StreamCallConfigRequest) XXX_Size() int

func (*StreamCallConfigRequest) XXX_Unmarshal 

func (m *StreamCallConfigRequest) XXX_Unmarshal(b []byte) error

type StreamCallConfigResponse 

type StreamCallConfigResponse struct {
	Method               string   `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCallConfigResponse) Descriptor 

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

func (*StreamCallConfigResponse) GetMethod 

func (m *StreamCallConfigResponse) GetMethod() string

func (*StreamCallConfigResponse) ProtoMessage 

func (*StreamCallConfigResponse) ProtoMessage()

func (*StreamCallConfigResponse) Reset 

func (m *StreamCallConfigResponse) Reset()

func (*StreamCallConfigResponse) String 

func (m *StreamCallConfigResponse) String() string

func (*StreamCallConfigResponse) Validate 

func (this *StreamCallConfigResponse) Validate() error

func (*StreamCallConfigResponse) XXX_DiscardUnknown 

func (m *StreamCallConfigResponse) XXX_DiscardUnknown()

func (*StreamCallConfigResponse) XXX_Marshal 

func (m *StreamCallConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCallConfigResponse) XXX_Merge 

func (m *StreamCallConfigResponse) XXX_Merge(src proto.Message)

func (*StreamCallConfigResponse) XXX_Size 

func (m *StreamCallConfigResponse) XXX_Size() int

func (*StreamCallConfigResponse) XXX_Unmarshal 

func (m *StreamCallConfigResponse) XXX_Unmarshal(b []byte) error

type StreamCallDataRequest 

type StreamCallDataRequest struct {
	Value                *any.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCallDataRequest) Descriptor 

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

func (*StreamCallDataRequest) GetValue 

func (m *StreamCallDataRequest) GetValue() *any.Any

func (*StreamCallDataRequest) ProtoMessage 

func (*StreamCallDataRequest) ProtoMessage()

func (*StreamCallDataRequest) Reset 

func (m *StreamCallDataRequest) Reset()

func (*StreamCallDataRequest) String 

func (m *StreamCallDataRequest) String() string

func (*StreamCallDataRequest) Validate 

func (this *StreamCallDataRequest) Validate() error

func (*StreamCallDataRequest) XXX_DiscardUnknown 

func (m *StreamCallDataRequest) XXX_DiscardUnknown()

func (*StreamCallDataRequest) XXX_Marshal 

func (m *StreamCallDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCallDataRequest) XXX_Merge 

func (m *StreamCallDataRequest) XXX_Merge(src proto.Message)

func (*StreamCallDataRequest) XXX_Size 

func (m *StreamCallDataRequest) XXX_Size() int

func (*StreamCallDataRequest) XXX_Unmarshal 

func (m *StreamCallDataRequest) XXX_Unmarshal(b []byte) error

type StreamCallDataResponse 

type StreamCallDataResponse struct {
	Value                *any.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCallDataResponse) Descriptor 

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

func (*StreamCallDataResponse) GetValue 

func (m *StreamCallDataResponse) GetValue() *any.Any

func (*StreamCallDataResponse) ProtoMessage 

func (*StreamCallDataResponse) ProtoMessage()

func (*StreamCallDataResponse) Reset 

func (m *StreamCallDataResponse) Reset()

func (*StreamCallDataResponse) String 

func (m *StreamCallDataResponse) String() string

func (*StreamCallDataResponse) Validate 

func (this *StreamCallDataResponse) Validate() error

func (*StreamCallDataResponse) XXX_DiscardUnknown 

func (m *StreamCallDataResponse) XXX_DiscardUnknown()

func (*StreamCallDataResponse) XXX_Marshal 

func (m *StreamCallDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCallDataResponse) XXX_Merge 

func (m *StreamCallDataResponse) XXX_Merge(src proto.Message)

func (*StreamCallDataResponse) XXX_Size 

func (m *StreamCallDataResponse) XXX_Size() int

func (*StreamCallDataResponse) XXX_Unmarshal 

func (m *StreamCallDataResponse) XXX_Unmarshal(b []byte) error

type StreamCallExit added in v1.0.0 

type StreamCallExit struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCallExit) Descriptor added in v1.0.0 

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

func (*StreamCallExit) ProtoMessage added in v1.0.0 

func (*StreamCallExit) ProtoMessage()

func (*StreamCallExit) Reset added in v1.0.0 

func (m *StreamCallExit) Reset()

func (*StreamCallExit) String added in v1.0.0 

func (m *StreamCallExit) String() string

func (*StreamCallExit) Validate added in v1.0.0 

func (this *StreamCallExit) Validate() error

func (*StreamCallExit) XXX_DiscardUnknown added in v1.0.0 

func (m *StreamCallExit) XXX_DiscardUnknown()

func (*StreamCallExit) XXX_Marshal added in v1.0.0 

func (m *StreamCallExit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCallExit) XXX_Merge added in v1.0.0 

func (m *StreamCallExit) XXX_Merge(src proto.Message)

func (*StreamCallExit) XXX_Size added in v1.0.0 

func (m *StreamCallExit) XXX_Size() int

func (*StreamCallExit) XXX_Unmarshal added in v1.0.0 

func (m *StreamCallExit) XXX_Unmarshal(b []byte) error

type StreamCallRequest 

type StreamCallRequest struct {
	// Types that are valid to be assigned to Request:
	//	*StreamCallRequest_Config
	//	*StreamCallRequest_Data
	Request              isStreamCallRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*StreamCallRequest) Descriptor 

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

func (*StreamCallRequest) GetConfig 

func (m *StreamCallRequest) GetConfig() *StreamCallConfigRequest

func (*StreamCallRequest) GetData 

func (m *StreamCallRequest) GetData() *StreamCallDataRequest

func (*StreamCallRequest) GetRequest 

func (m *StreamCallRequest) GetRequest() isStreamCallRequest_Request

func (*StreamCallRequest) ProtoMessage 

func (*StreamCallRequest) ProtoMessage()

func (*StreamCallRequest) Reset 

func (m *StreamCallRequest) Reset()

func (*StreamCallRequest) String 

func (m *StreamCallRequest) String() string

func (*StreamCallRequest) Validate 

func (this *StreamCallRequest) Validate() error

func (*StreamCallRequest) XXX_DiscardUnknown 

func (m *StreamCallRequest) XXX_DiscardUnknown()

func (*StreamCallRequest) XXX_Marshal 

func (m *StreamCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCallRequest) XXX_Merge 

func (m *StreamCallRequest) XXX_Merge(src proto.Message)

func (*StreamCallRequest) XXX_OneofWrappers added in v1.0.0 

func (*StreamCallRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamCallRequest) XXX_Size 

func (m *StreamCallRequest) XXX_Size() int

func (*StreamCallRequest) XXX_Unmarshal 

func (m *StreamCallRequest) XXX_Unmarshal(b []byte) error

type StreamCallRequest_Config 

type StreamCallRequest_Config struct {
	Config *StreamCallConfigRequest `protobuf:"bytes,1,opt,name=config,proto3,oneof"`
}

type StreamCallRequest_Data 

type StreamCallRequest_Data struct {
	Data *StreamCallDataRequest `protobuf:"bytes,21,opt,name=data,proto3,oneof"`
}

type StreamCallResponse 

type StreamCallResponse struct {
	// Types that are valid to be assigned to Response:
	//	*StreamCallResponse_Config
	//	*StreamCallResponse_Data
	Response             isStreamCallResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*StreamCallResponse) Descriptor 

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

func (*StreamCallResponse) GetConfig 

func (m *StreamCallResponse) GetConfig() *StreamCallConfigResponse

func (*StreamCallResponse) GetData 

func (m *StreamCallResponse) GetData() *StreamCallDataResponse

func (*StreamCallResponse) GetResponse 

func (m *StreamCallResponse) GetResponse() isStreamCallResponse_Response

func (*StreamCallResponse) ProtoMessage 

func (*StreamCallResponse) ProtoMessage()

func (*StreamCallResponse) Reset 

func (m *StreamCallResponse) Reset()

func (*StreamCallResponse) String 

func (m *StreamCallResponse) String() string

func (*StreamCallResponse) Validate 

func (this *StreamCallResponse) Validate() error

func (*StreamCallResponse) XXX_DiscardUnknown 

func (m *StreamCallResponse) XXX_DiscardUnknown()

func (*StreamCallResponse) XXX_Marshal 

func (m *StreamCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCallResponse) XXX_Merge 

func (m *StreamCallResponse) XXX_Merge(src proto.Message)

func (*StreamCallResponse) XXX_OneofWrappers added in v1.0.0 

func (*StreamCallResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamCallResponse) XXX_Size 

func (m *StreamCallResponse) XXX_Size() int

func (*StreamCallResponse) XXX_Unmarshal 

func (m *StreamCallResponse) XXX_Unmarshal(b []byte) error

type StreamCallResponse_Config 

type StreamCallResponse_Config struct {
	Config *StreamCallConfigResponse `protobuf:"bytes,1,opt,name=config,proto3,oneof"`
}

type StreamCallResponse_Data 

type StreamCallResponse_Data struct {
	Data *StreamCallDataResponse `protobuf:"bytes,21,opt,name=data,proto3,oneof"`
}

type StreamCallValue added in v1.0.0 

type StreamCallValue struct {
	// Types that are valid to be assigned to Union:
	//	*StreamCallValue_Value
	//	*StreamCallValue_Config
	//	*StreamCallValue_Ack
	//	*StreamCallValue_Exit
	Union                isStreamCallValue_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*StreamCallValue) Descriptor added in v1.0.0 

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

func (*StreamCallValue) GetAck added in v1.0.0 

func (m *StreamCallValue) GetAck() *StreamCallAck

func (*StreamCallValue) GetConfig added in v1.0.0 

func (m *StreamCallValue) GetConfig() *StreamCallConfig

func (*StreamCallValue) GetExit added in v1.0.0 

func (m *StreamCallValue) GetExit() *StreamCallExit

func (*StreamCallValue) GetUnion added in v1.0.0 

func (m *StreamCallValue) GetUnion() isStreamCallValue_Union

func (*StreamCallValue) GetValue added in v1.0.0 

func (m *StreamCallValue) GetValue() *any.Any

func (*StreamCallValue) ProtoMessage added in v1.0.0 

func (*StreamCallValue) ProtoMessage()

func (*StreamCallValue) Reset added in v1.0.0 

func (m *StreamCallValue) Reset()

func (*StreamCallValue) String added in v1.0.0 

func (m *StreamCallValue) String() string

func (*StreamCallValue) Validate added in v1.0.0 

func (this *StreamCallValue) Validate() error

func (*StreamCallValue) XXX_DiscardUnknown added in v1.0.0 

func (m *StreamCallValue) XXX_DiscardUnknown()

func (*StreamCallValue) XXX_Marshal added in v1.0.0 

func (m *StreamCallValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCallValue) XXX_Merge added in v1.0.0 

func (m *StreamCallValue) XXX_Merge(src proto.Message)

func (*StreamCallValue) XXX_OneofWrappers added in v1.0.0 

func (*StreamCallValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamCallValue) XXX_Size added in v1.0.0 

func (m *StreamCallValue) XXX_Size() int

func (*StreamCallValue) XXX_Unmarshal added in v1.0.0 

func (m *StreamCallValue) XXX_Unmarshal(b []byte) error

type StreamCallValue_Ack added in v1.0.0 

type StreamCallValue_Ack struct {
	Ack *StreamCallAck `protobuf:"bytes,3,opt,name=ack,proto3,oneof"`
}

type StreamCallValue_Config added in v1.0.0 

type StreamCallValue_Config struct {
	Config *StreamCallConfig `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type StreamCallValue_Exit added in v1.0.0 

type StreamCallValue_Exit struct {
	Exit *StreamCallExit `protobuf:"bytes,4,opt,name=exit,proto3,oneof"`
}

type StreamCallValue_Value added in v1.0.0 

type StreamCallValue_Value struct {
	Value *any.Any `protobuf:"bytes,1,opt,name=value,proto3,oneof"`
}

type StreamFrameKind added in v1.0.0 

type StreamFrameKind int32
const (
	StreamFrameKind_STREAM_FRAME_KIND_UNKNOWN StreamFrameKind = 0
	StreamFrameKind_STREAM_FRAME_KIND_SYSTEM  StreamFrameKind = 1
	StreamFrameKind_STREAM_FRAME_KIND_USER    StreamFrameKind = 2
)

func (StreamFrameKind) EnumDescriptor added in v1.0.0 

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

func (StreamFrameKind) String added in v1.0.0 

func (x StreamFrameKind) String() string

type UnaryCallRequest 

type UnaryCallRequest struct {
	Method               *wrappers.StringValue `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Value                *any.Any              `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*UnaryCallRequest) Descriptor 

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

func (*UnaryCallRequest) GetMethod 

func (m *UnaryCallRequest) GetMethod() *wrappers.StringValue

func (*UnaryCallRequest) GetValue 

func (m *UnaryCallRequest) GetValue() *any.Any

func (*UnaryCallRequest) ProtoMessage 

func (*UnaryCallRequest) ProtoMessage()

func (*UnaryCallRequest) Reset 

func (m *UnaryCallRequest) Reset()

func (*UnaryCallRequest) String 

func (m *UnaryCallRequest) String() string

func (*UnaryCallRequest) Validate 

func (this *UnaryCallRequest) Validate() error

func (*UnaryCallRequest) XXX_DiscardUnknown 

func (m *UnaryCallRequest) XXX_DiscardUnknown()

func (*UnaryCallRequest) XXX_Marshal 

func (m *UnaryCallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnaryCallRequest) XXX_Merge 

func (m *UnaryCallRequest) XXX_Merge(src proto.Message)

func (*UnaryCallRequest) XXX_Size 

func (m *UnaryCallRequest) XXX_Size() int

func (*UnaryCallRequest) XXX_Unmarshal 

func (m *UnaryCallRequest) XXX_Unmarshal(b []byte) error

type UnaryCallResponse 

type UnaryCallResponse struct {
	Method               string   `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Value                *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnaryCallResponse) Descriptor 

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

func (*UnaryCallResponse) GetMethod 

func (m *UnaryCallResponse) GetMethod() string

func (*UnaryCallResponse) GetValue 

func (m *UnaryCallResponse) GetValue() *any.Any

func (*UnaryCallResponse) ProtoMessage 

func (*UnaryCallResponse) ProtoMessage()

func (*UnaryCallResponse) Reset 

func (m *UnaryCallResponse) Reset()

func (*UnaryCallResponse) String 

func (m *UnaryCallResponse) String() string

func (*UnaryCallResponse) Validate 

func (this *UnaryCallResponse) Validate() error

func (*UnaryCallResponse) XXX_DiscardUnknown 

func (m *UnaryCallResponse) XXX_DiscardUnknown()

func (*UnaryCallResponse) XXX_Marshal 

func (m *UnaryCallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnaryCallResponse) XXX_Merge 

func (m *UnaryCallResponse) XXX_Merge(src proto.Message)

func (*UnaryCallResponse) XXX_Size 

func (m *UnaryCallResponse) XXX_Size() int

func (*UnaryCallResponse) XXX_Unmarshal 

func (m *UnaryCallResponse) XXX_Unmarshal(b []byte) error

type UnaryCallValue added in v1.0.0 

type UnaryCallValue struct {
	Session              int64    `protobuf:"varint,1,opt,name=session,proto3" json:"session,omitempty"`
	Method               string   `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Value                *any.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnaryCallValue) Descriptor added in v1.0.0 

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

func (*UnaryCallValue) GetMethod added in v1.0.0 

func (m *UnaryCallValue) GetMethod() string

func (*UnaryCallValue) GetSession added in v1.0.0 

func (m *UnaryCallValue) GetSession() int64

func (*UnaryCallValue) GetValue added in v1.0.0 

func (m *UnaryCallValue) GetValue() *any.Any

func (*UnaryCallValue) ProtoMessage added in v1.0.0 

func (*UnaryCallValue) ProtoMessage()

func (*UnaryCallValue) Reset added in v1.0.0 

func (m *UnaryCallValue) Reset()

func (*UnaryCallValue) String added in v1.0.0 

func (m *UnaryCallValue) String() string

func (*UnaryCallValue) Validate added in v1.0.0 

func (this *UnaryCallValue) Validate() error

func (*UnaryCallValue) XXX_DiscardUnknown added in v1.0.0 

func (m *UnaryCallValue) XXX_DiscardUnknown()

func (*UnaryCallValue) XXX_Marshal added in v1.0.0 

func (m *UnaryCallValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnaryCallValue) XXX_Merge added in v1.0.0 

func (m *UnaryCallValue) XXX_Merge(src proto.Message)

func (*UnaryCallValue) XXX_Size added in v1.0.0 

func (m *UnaryCallValue) XXX_Size() int

func (*UnaryCallValue) XXX_Unmarshal added in v1.0.0 

func (m *UnaryCallValue) XXX_Unmarshal(b []byte) error

type UnimplementedModuleServiceServer added in v1.0.0 

type UnimplementedModuleServiceServer struct {
}

UnimplementedModuleServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedModuleServiceServer) StreamCall added in v1.0.0 

func (*UnimplementedModuleServiceServer) StreamCall(srv ModuleService_StreamCallServer) error

func (*UnimplementedModuleServiceServer) UnaryCall added in v1.0.0 

func (*UnimplementedModuleServiceServer) UnaryCall(ctx context.Context, req *UnaryCallRequest) (*UnaryCallResponse, error)

type UpStreamFrame added in v1.0.0 

type UpStreamFrame struct {
	Kind StreamFrameKind `protobuf:"varint,1,opt,name=kind,proto3,enum=ai.metathings.component.StreamFrameKind" json:"kind,omitempty"`
	// Types that are valid to be assigned to Union:
	//	*UpStreamFrame_UnaryCall
	//	*UpStreamFrame_StreamCall
	//	*UpStreamFrame_Error
	Union                isUpStreamFrame_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*UpStreamFrame) Descriptor added in v1.0.0 

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

func (*UpStreamFrame) GetError added in v1.0.0 

func (m *UpStreamFrame) GetError() *ErrorValue

func (*UpStreamFrame) GetKind added in v1.0.0 

func (m *UpStreamFrame) GetKind() StreamFrameKind

func (*UpStreamFrame) GetStreamCall added in v1.0.0 

func (m *UpStreamFrame) GetStreamCall() *StreamCallValue

func (*UpStreamFrame) GetUnaryCall added in v1.0.0 

func (m *UpStreamFrame) GetUnaryCall() *UnaryCallValue

func (*UpStreamFrame) GetUnion added in v1.0.0 

func (m *UpStreamFrame) GetUnion() isUpStreamFrame_Union

func (*UpStreamFrame) ProtoMessage added in v1.0.0 

func (*UpStreamFrame) ProtoMessage()

func (*UpStreamFrame) Reset added in v1.0.0 

func (m *UpStreamFrame) Reset()

func (*UpStreamFrame) String added in v1.0.0 

func (m *UpStreamFrame) String() string

func (*UpStreamFrame) Validate added in v1.0.0 

func (this *UpStreamFrame) Validate() error

func (*UpStreamFrame) XXX_DiscardUnknown added in v1.0.0 

func (m *UpStreamFrame) XXX_DiscardUnknown()

func (*UpStreamFrame) XXX_Marshal added in v1.0.0 

func (m *UpStreamFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpStreamFrame) XXX_Merge added in v1.0.0 

func (m *UpStreamFrame) XXX_Merge(src proto.Message)

func (*UpStreamFrame) XXX_OneofWrappers added in v1.0.0 

func (*UpStreamFrame) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*UpStreamFrame) XXX_Size added in v1.0.0 

func (m *UpStreamFrame) XXX_Size() int

func (*UpStreamFrame) XXX_Unmarshal added in v1.0.0 

func (m *UpStreamFrame) XXX_Unmarshal(b []byte) error

type UpStreamFrame_Error added in v1.0.0 

type UpStreamFrame_Error struct {
	Error *ErrorValue `protobuf:"bytes,9,opt,name=error,proto3,oneof"`
}

type UpStreamFrame_StreamCall added in v1.0.0 

type UpStreamFrame_StreamCall struct {
	StreamCall *StreamCallValue `protobuf:"bytes,3,opt,name=stream_call,json=streamCall,proto3,oneof"`
}

type UpStreamFrame_UnaryCall added in v1.0.0 

type UpStreamFrame_UnaryCall struct {
	UnaryCall *UnaryCallValue `protobuf:"bytes,2,opt,name=unary_call,json=unaryCall,proto3,oneof"`
}

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.