component

package
v1.2.8 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2020 License: MIT Imports: 18 Imported by: 1

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 

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 

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

func (*DownStreamFrame) GetKind 

func (m *DownStreamFrame) GetKind() StreamFrameKind

func (*DownStreamFrame) GetStreamCall 

func (m *DownStreamFrame) GetStreamCall() *OpStreamCallValue

func (*DownStreamFrame) GetUnaryCall 

func (m *DownStreamFrame) GetUnaryCall() *OpUnaryCallValue

func (*DownStreamFrame) GetUnion 

func (m *DownStreamFrame) GetUnion() isDownStreamFrame_Union

func (*DownStreamFrame) ProtoMessage 

func (*DownStreamFrame) ProtoMessage()

func (*DownStreamFrame) Reset 

func (m *DownStreamFrame) Reset()

func (*DownStreamFrame) String 

func (m *DownStreamFrame) String() string

func (*DownStreamFrame) Validate 

func (m *DownStreamFrame) Validate() error

Validate checks the field values on DownStreamFrame with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*DownStreamFrame) XXX_DiscardUnknown 

func (m *DownStreamFrame) XXX_DiscardUnknown()

func (*DownStreamFrame) XXX_Marshal 

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

func (*DownStreamFrame) XXX_Merge 

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

func (*DownStreamFrame) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DownStreamFrame) XXX_Size 

func (m *DownStreamFrame) XXX_Size() int

func (*DownStreamFrame) XXX_Unmarshal 

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

type DownStreamFrameValidationError 

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

DownStreamFrameValidationError is the validation error returned by DownStreamFrame.Validate if the designated constraints aren't met.

func (DownStreamFrameValidationError) Cause 

func (e DownStreamFrameValidationError) Cause() error

Cause function returns cause value.

func (DownStreamFrameValidationError) Error 

func (e DownStreamFrameValidationError) Error() string

Error satisfies the builtin error interface

func (DownStreamFrameValidationError) ErrorName 

func (e DownStreamFrameValidationError) ErrorName() string

ErrorName returns error name.

func (DownStreamFrameValidationError) Field 

func (e DownStreamFrameValidationError) Field() string

Field function returns field value.

func (DownStreamFrameValidationError) Key 

func (e DownStreamFrameValidationError) Key() bool

Key function returns key value.

func (DownStreamFrameValidationError) Reason 

func (e DownStreamFrameValidationError) Reason() string

Reason function returns reason value.

type DownStreamFrame_StreamCall 

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

type DownStreamFrame_UnaryCall 

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

type ErrorValue 

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 

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

func (*ErrorValue) GetCode 

func (m *ErrorValue) GetCode() int64

func (*ErrorValue) GetMessage 

func (m *ErrorValue) GetMessage() string

func (*ErrorValue) ProtoMessage 

func (*ErrorValue) ProtoMessage()

func (*ErrorValue) Reset 

func (m *ErrorValue) Reset()

func (*ErrorValue) String 

func (m *ErrorValue) String() string

func (*ErrorValue) Validate 

func (m *ErrorValue) Validate() error

Validate checks the field values on ErrorValue with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ErrorValue) XXX_DiscardUnknown 

func (m *ErrorValue) XXX_DiscardUnknown()

func (*ErrorValue) XXX_Marshal 

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

func (*ErrorValue) XXX_Merge 

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

func (*ErrorValue) XXX_Size 

func (m *ErrorValue) XXX_Size() int

func (*ErrorValue) XXX_Unmarshal 

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

type ErrorValueValidationError 

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

ErrorValueValidationError is the validation error returned by ErrorValue.Validate if the designated constraints aren't met.

func (ErrorValueValidationError) Cause 

func (e ErrorValueValidationError) Cause() error

Cause function returns cause value.

func (ErrorValueValidationError) Error 

func (e ErrorValueValidationError) Error() string

Error satisfies the builtin error interface

func (ErrorValueValidationError) ErrorName 

func (e ErrorValueValidationError) ErrorName() string

ErrorName returns error name.

func (ErrorValueValidationError) Field 

func (e ErrorValueValidationError) Field() string

Field function returns field value.

func (ErrorValueValidationError) Key 

func (e ErrorValueValidationError) Key() bool

Key function returns key value.

func (ErrorValueValidationError) Reason 

func (e ErrorValueValidationError) Reason() string

Reason function returns reason value.

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 

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 

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

func (*OpStreamCallAck) GetValue 

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

func (*OpStreamCallAck) ProtoMessage 

func (*OpStreamCallAck) ProtoMessage()

func (*OpStreamCallAck) Reset 

func (m *OpStreamCallAck) Reset()

func (*OpStreamCallAck) String 

func (m *OpStreamCallAck) String() string

func (*OpStreamCallAck) Validate 

func (m *OpStreamCallAck) Validate() error

Validate checks the field values on OpStreamCallAck with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*OpStreamCallAck) XXX_DiscardUnknown 

func (m *OpStreamCallAck) XXX_DiscardUnknown()

func (*OpStreamCallAck) XXX_Marshal 

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

func (*OpStreamCallAck) XXX_Merge 

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

func (*OpStreamCallAck) XXX_Size 

func (m *OpStreamCallAck) XXX_Size() int

func (*OpStreamCallAck) XXX_Unmarshal 

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

type OpStreamCallAckValidationError 

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

OpStreamCallAckValidationError is the validation error returned by OpStreamCallAck.Validate if the designated constraints aren't met.

func (OpStreamCallAckValidationError) Cause 

func (e OpStreamCallAckValidationError) Cause() error

Cause function returns cause value.

func (OpStreamCallAckValidationError) Error 

func (e OpStreamCallAckValidationError) Error() string

Error satisfies the builtin error interface

func (OpStreamCallAckValidationError) ErrorName 

func (e OpStreamCallAckValidationError) ErrorName() string

ErrorName returns error name.

func (OpStreamCallAckValidationError) Field 

func (e OpStreamCallAckValidationError) Field() string

Field function returns field value.

func (OpStreamCallAckValidationError) Key 

func (e OpStreamCallAckValidationError) Key() bool

Key function returns key value.

func (OpStreamCallAckValidationError) Reason 

func (e OpStreamCallAckValidationError) Reason() string

Reason function returns reason value.

type OpStreamCallConfig 

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 

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

func (*OpStreamCallConfig) GetAck 

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

func (*OpStreamCallConfig) GetMethod 

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

func (*OpStreamCallConfig) GetSession 

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

func (*OpStreamCallConfig) ProtoMessage 

func (*OpStreamCallConfig) ProtoMessage()

func (*OpStreamCallConfig) Reset 

func (m *OpStreamCallConfig) Reset()

func (*OpStreamCallConfig) String 

func (m *OpStreamCallConfig) String() string

func (*OpStreamCallConfig) Validate 

func (m *OpStreamCallConfig) Validate() error

Validate checks the field values on OpStreamCallConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*OpStreamCallConfig) XXX_DiscardUnknown 

func (m *OpStreamCallConfig) XXX_DiscardUnknown()

func (*OpStreamCallConfig) XXX_Marshal 

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

func (*OpStreamCallConfig) XXX_Merge 

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

func (*OpStreamCallConfig) XXX_Size 

func (m *OpStreamCallConfig) XXX_Size() int

func (*OpStreamCallConfig) XXX_Unmarshal 

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

type OpStreamCallConfigValidationError 

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

OpStreamCallConfigValidationError is the validation error returned by OpStreamCallConfig.Validate if the designated constraints aren't met.

func (OpStreamCallConfigValidationError) Cause 

func (e OpStreamCallConfigValidationError) Cause() error

Cause function returns cause value.

func (OpStreamCallConfigValidationError) Error 

func (e OpStreamCallConfigValidationError) Error() string

Error satisfies the builtin error interface

func (OpStreamCallConfigValidationError) ErrorName 

func (e OpStreamCallConfigValidationError) ErrorName() string

ErrorName returns error name.

func (OpStreamCallConfigValidationError) Field 

func (e OpStreamCallConfigValidationError) Field() string

Field function returns field value.

func (OpStreamCallConfigValidationError) Key 

func (e OpStreamCallConfigValidationError) Key() bool

Key function returns key value.

func (OpStreamCallConfigValidationError) Reason 

func (e OpStreamCallConfigValidationError) Reason() string

Reason function returns reason value.

type OpStreamCallExit 

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

func (*OpStreamCallExit) Descriptor 

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

func (*OpStreamCallExit) ProtoMessage 

func (*OpStreamCallExit) ProtoMessage()

func (*OpStreamCallExit) Reset 

func (m *OpStreamCallExit) Reset()

func (*OpStreamCallExit) String 

func (m *OpStreamCallExit) String() string

func (*OpStreamCallExit) Validate 

func (m *OpStreamCallExit) Validate() error

Validate checks the field values on OpStreamCallExit with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*OpStreamCallExit) XXX_DiscardUnknown 

func (m *OpStreamCallExit) XXX_DiscardUnknown()

func (*OpStreamCallExit) XXX_Marshal 

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

func (*OpStreamCallExit) XXX_Merge 

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

func (*OpStreamCallExit) XXX_Size 

func (m *OpStreamCallExit) XXX_Size() int

func (*OpStreamCallExit) XXX_Unmarshal 

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

type OpStreamCallExitValidationError 

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

OpStreamCallExitValidationError is the validation error returned by OpStreamCallExit.Validate if the designated constraints aren't met.

func (OpStreamCallExitValidationError) Cause 

func (e OpStreamCallExitValidationError) Cause() error

Cause function returns cause value.

func (OpStreamCallExitValidationError) Error 

func (e OpStreamCallExitValidationError) Error() string

Error satisfies the builtin error interface

func (OpStreamCallExitValidationError) ErrorName 

func (e OpStreamCallExitValidationError) ErrorName() string

ErrorName returns error name.

func (OpStreamCallExitValidationError) Field 

func (e OpStreamCallExitValidationError) Field() string

Field function returns field value.

func (OpStreamCallExitValidationError) Key 

func (e OpStreamCallExitValidationError) Key() bool

Key function returns key value.

func (OpStreamCallExitValidationError) Reason 

func (e OpStreamCallExitValidationError) Reason() string

Reason function returns reason value.

type OpStreamCallValue 

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 

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

func (*OpStreamCallValue) GetAck 

func (m *OpStreamCallValue) GetAck() *OpStreamCallAck

func (*OpStreamCallValue) GetConfig 

func (m *OpStreamCallValue) GetConfig() *OpStreamCallConfig

func (*OpStreamCallValue) GetExit 

func (m *OpStreamCallValue) GetExit() *OpStreamCallExit

func (*OpStreamCallValue) GetUnion 

func (m *OpStreamCallValue) GetUnion() isOpStreamCallValue_Union

func (*OpStreamCallValue) GetValue 

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

func (*OpStreamCallValue) ProtoMessage 

func (*OpStreamCallValue) ProtoMessage()

func (*OpStreamCallValue) Reset 

func (m *OpStreamCallValue) Reset()

func (*OpStreamCallValue) String 

func (m *OpStreamCallValue) String() string

func (*OpStreamCallValue) Validate 

func (m *OpStreamCallValue) Validate() error

Validate checks the field values on OpStreamCallValue with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*OpStreamCallValue) XXX_DiscardUnknown 

func (m *OpStreamCallValue) XXX_DiscardUnknown()

func (*OpStreamCallValue) XXX_Marshal 

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

func (*OpStreamCallValue) XXX_Merge 

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

func (*OpStreamCallValue) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*OpStreamCallValue) XXX_Size 

func (m *OpStreamCallValue) XXX_Size() int

func (*OpStreamCallValue) XXX_Unmarshal 

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

type OpStreamCallValueValidationError 

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

OpStreamCallValueValidationError is the validation error returned by OpStreamCallValue.Validate if the designated constraints aren't met.

func (OpStreamCallValueValidationError) Cause 

func (e OpStreamCallValueValidationError) Cause() error

Cause function returns cause value.

func (OpStreamCallValueValidationError) Error 

func (e OpStreamCallValueValidationError) Error() string

Error satisfies the builtin error interface

func (OpStreamCallValueValidationError) ErrorName 

func (e OpStreamCallValueValidationError) ErrorName() string

ErrorName returns error name.

func (OpStreamCallValueValidationError) Field 

func (e OpStreamCallValueValidationError) Field() string

Field function returns field value.

func (OpStreamCallValueValidationError) Key 

func (e OpStreamCallValueValidationError) Key() bool

Key function returns key value.

func (OpStreamCallValueValidationError) Reason 

func (e OpStreamCallValueValidationError) Reason() string

Reason function returns reason value.

type OpStreamCallValue_Ack 

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

type OpStreamCallValue_Config 

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

type OpStreamCallValue_Exit 

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

type OpStreamCallValue_Value 

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

type OpUnaryCallValue 

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 

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

func (*OpUnaryCallValue) GetMethod 

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

func (*OpUnaryCallValue) GetSession 

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

func (*OpUnaryCallValue) GetValue 

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

func (*OpUnaryCallValue) ProtoMessage 

func (*OpUnaryCallValue) ProtoMessage()

func (*OpUnaryCallValue) Reset 

func (m *OpUnaryCallValue) Reset()

func (*OpUnaryCallValue) String 

func (m *OpUnaryCallValue) String() string

func (*OpUnaryCallValue) Validate 

func (m *OpUnaryCallValue) Validate() error

Validate checks the field values on OpUnaryCallValue with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*OpUnaryCallValue) XXX_DiscardUnknown 

func (m *OpUnaryCallValue) XXX_DiscardUnknown()

func (*OpUnaryCallValue) XXX_Marshal 

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

func (*OpUnaryCallValue) XXX_Merge 

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

func (*OpUnaryCallValue) XXX_Size 

func (m *OpUnaryCallValue) XXX_Size() int

func (*OpUnaryCallValue) XXX_Unmarshal 

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

type OpUnaryCallValueValidationError 

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

OpUnaryCallValueValidationError is the validation error returned by OpUnaryCallValue.Validate if the designated constraints aren't met.

func (OpUnaryCallValueValidationError) Cause 

func (e OpUnaryCallValueValidationError) Cause() error

Cause function returns cause value.

func (OpUnaryCallValueValidationError) Error 

func (e OpUnaryCallValueValidationError) Error() string

Error satisfies the builtin error interface

func (OpUnaryCallValueValidationError) ErrorName 

func (e OpUnaryCallValueValidationError) ErrorName() string

ErrorName returns error name.

func (OpUnaryCallValueValidationError) Field 

func (e OpUnaryCallValueValidationError) Field() string

Field function returns field value.

func (OpUnaryCallValueValidationError) Key 

func (e OpUnaryCallValueValidationError) Key() bool

Key function returns key value.

func (OpUnaryCallValueValidationError) Reason 

func (e OpUnaryCallValueValidationError) Reason() string

Reason function returns reason value.

type StreamCallAck 

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 

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

func (*StreamCallAck) GetValue 

func (m *StreamCallAck) GetValue() int64

func (*StreamCallAck) ProtoMessage 

func (*StreamCallAck) ProtoMessage()

func (*StreamCallAck) Reset 

func (m *StreamCallAck) Reset()

func (*StreamCallAck) String 

func (m *StreamCallAck) String() string

func (*StreamCallAck) Validate 

func (m *StreamCallAck) Validate() error

Validate checks the field values on StreamCallAck with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*StreamCallAck) XXX_DiscardUnknown 

func (m *StreamCallAck) XXX_DiscardUnknown()

func (*StreamCallAck) XXX_Marshal 

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

func (*StreamCallAck) XXX_Merge 

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

func (*StreamCallAck) XXX_Size 

func (m *StreamCallAck) XXX_Size() int

func (*StreamCallAck) XXX_Unmarshal 

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

type StreamCallAckValidationError 

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

StreamCallAckValidationError is the validation error returned by StreamCallAck.Validate if the designated constraints aren't met.

func (StreamCallAckValidationError) Cause 

func (e StreamCallAckValidationError) Cause() error

Cause function returns cause value.

func (StreamCallAckValidationError) Error 

func (e StreamCallAckValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCallAckValidationError) ErrorName 

func (e StreamCallAckValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCallAckValidationError) Field 

func (e StreamCallAckValidationError) Field() string

Field function returns field value.

func (StreamCallAckValidationError) Key 

func (e StreamCallAckValidationError) Key() bool

Key function returns key value.

func (StreamCallAckValidationError) Reason 

func (e StreamCallAckValidationError) Reason() string

Reason function returns reason value.

type StreamCallConfig 

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 

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

func (*StreamCallConfig) GetAck 

func (m *StreamCallConfig) GetAck() int64

func (*StreamCallConfig) GetMethod 

func (m *StreamCallConfig) GetMethod() string

func (*StreamCallConfig) GetSession 

func (m *StreamCallConfig) GetSession() int64

func (*StreamCallConfig) ProtoMessage 

func (*StreamCallConfig) ProtoMessage()

func (*StreamCallConfig) Reset 

func (m *StreamCallConfig) Reset()

func (*StreamCallConfig) String 

func (m *StreamCallConfig) String() string

func (*StreamCallConfig) Validate 

func (m *StreamCallConfig) Validate() error

Validate checks the field values on StreamCallConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*StreamCallConfig) XXX_DiscardUnknown 

func (m *StreamCallConfig) XXX_DiscardUnknown()

func (*StreamCallConfig) XXX_Marshal 

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

func (*StreamCallConfig) XXX_Merge 

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

func (*StreamCallConfig) XXX_Size 

func (m *StreamCallConfig) XXX_Size() int

func (*StreamCallConfig) XXX_Unmarshal 

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 (m *StreamCallConfigRequest) Validate() error

Validate checks the field values on StreamCallConfigRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 StreamCallConfigRequestValidationError 

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

StreamCallConfigRequestValidationError is the validation error returned by StreamCallConfigRequest.Validate if the designated constraints aren't met.

func (StreamCallConfigRequestValidationError) Cause 

func (e StreamCallConfigRequestValidationError) Cause() error

Cause function returns cause value.

func (StreamCallConfigRequestValidationError) Error 

func (e StreamCallConfigRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCallConfigRequestValidationError) ErrorName 

func (e StreamCallConfigRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCallConfigRequestValidationError) Field 

func (e StreamCallConfigRequestValidationError) Field() string

Field function returns field value.

func (StreamCallConfigRequestValidationError) Key 

func (e StreamCallConfigRequestValidationError) Key() bool

Key function returns key value.

func (StreamCallConfigRequestValidationError) Reason 

func (e StreamCallConfigRequestValidationError) Reason() string

Reason function returns reason value.

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 (m *StreamCallConfigResponse) Validate() error

Validate checks the field values on StreamCallConfigResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 StreamCallConfigResponseValidationError 

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

StreamCallConfigResponseValidationError is the validation error returned by StreamCallConfigResponse.Validate if the designated constraints aren't met.

func (StreamCallConfigResponseValidationError) Cause 

func (e StreamCallConfigResponseValidationError) Cause() error

Cause function returns cause value.

func (StreamCallConfigResponseValidationError) Error 

func (e StreamCallConfigResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCallConfigResponseValidationError) ErrorName 

func (e StreamCallConfigResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCallConfigResponseValidationError) Field 

func (e StreamCallConfigResponseValidationError) Field() string

Field function returns field value.

func (StreamCallConfigResponseValidationError) Key 

func (e StreamCallConfigResponseValidationError) Key() bool

Key function returns key value.

func (StreamCallConfigResponseValidationError) Reason 

func (e StreamCallConfigResponseValidationError) Reason() string

Reason function returns reason value.

type StreamCallConfigValidationError 

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

StreamCallConfigValidationError is the validation error returned by StreamCallConfig.Validate if the designated constraints aren't met.

func (StreamCallConfigValidationError) Cause 

func (e StreamCallConfigValidationError) Cause() error

Cause function returns cause value.

func (StreamCallConfigValidationError) Error 

func (e StreamCallConfigValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCallConfigValidationError) ErrorName 

func (e StreamCallConfigValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCallConfigValidationError) Field 

func (e StreamCallConfigValidationError) Field() string

Field function returns field value.

func (StreamCallConfigValidationError) Key 

func (e StreamCallConfigValidationError) Key() bool

Key function returns key value.

func (StreamCallConfigValidationError) Reason 

func (e StreamCallConfigValidationError) Reason() string

Reason function returns reason value.

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 (m *StreamCallDataRequest) Validate() error

Validate checks the field values on StreamCallDataRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 StreamCallDataRequestValidationError 

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

StreamCallDataRequestValidationError is the validation error returned by StreamCallDataRequest.Validate if the designated constraints aren't met.

func (StreamCallDataRequestValidationError) Cause 

func (e StreamCallDataRequestValidationError) Cause() error

Cause function returns cause value.

func (StreamCallDataRequestValidationError) Error 

func (e StreamCallDataRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCallDataRequestValidationError) ErrorName 

func (e StreamCallDataRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCallDataRequestValidationError) Field 

func (e StreamCallDataRequestValidationError) Field() string

Field function returns field value.

func (StreamCallDataRequestValidationError) Key 

func (e StreamCallDataRequestValidationError) Key() bool

Key function returns key value.

func (StreamCallDataRequestValidationError) Reason 

func (e StreamCallDataRequestValidationError) Reason() string

Reason function returns reason value.

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 (m *StreamCallDataResponse) Validate() error

Validate checks the field values on StreamCallDataResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 StreamCallDataResponseValidationError 

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

StreamCallDataResponseValidationError is the validation error returned by StreamCallDataResponse.Validate if the designated constraints aren't met.

func (StreamCallDataResponseValidationError) Cause 

func (e StreamCallDataResponseValidationError) Cause() error

Cause function returns cause value.

func (StreamCallDataResponseValidationError) Error 

func (e StreamCallDataResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCallDataResponseValidationError) ErrorName 

func (e StreamCallDataResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCallDataResponseValidationError) Field 

func (e StreamCallDataResponseValidationError) Field() string

Field function returns field value.

func (StreamCallDataResponseValidationError) Key 

func (e StreamCallDataResponseValidationError) Key() bool

Key function returns key value.

func (StreamCallDataResponseValidationError) Reason 

func (e StreamCallDataResponseValidationError) Reason() string

Reason function returns reason value.

type StreamCallExit 

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

func (*StreamCallExit) Descriptor 

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

func (*StreamCallExit) ProtoMessage 

func (*StreamCallExit) ProtoMessage()

func (*StreamCallExit) Reset 

func (m *StreamCallExit) Reset()

func (*StreamCallExit) String 

func (m *StreamCallExit) String() string

func (*StreamCallExit) Validate 

func (m *StreamCallExit) Validate() error

Validate checks the field values on StreamCallExit with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*StreamCallExit) XXX_DiscardUnknown 

func (m *StreamCallExit) XXX_DiscardUnknown()

func (*StreamCallExit) XXX_Marshal 

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

func (*StreamCallExit) XXX_Merge 

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

func (*StreamCallExit) XXX_Size 

func (m *StreamCallExit) XXX_Size() int

func (*StreamCallExit) XXX_Unmarshal 

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

type StreamCallExitValidationError 

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

StreamCallExitValidationError is the validation error returned by StreamCallExit.Validate if the designated constraints aren't met.

func (StreamCallExitValidationError) Cause 

func (e StreamCallExitValidationError) Cause() error

Cause function returns cause value.

func (StreamCallExitValidationError) Error 

func (e StreamCallExitValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCallExitValidationError) ErrorName 

func (e StreamCallExitValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCallExitValidationError) Field 

func (e StreamCallExitValidationError) Field() string

Field function returns field value.

func (StreamCallExitValidationError) Key 

func (e StreamCallExitValidationError) Key() bool

Key function returns key value.

func (StreamCallExitValidationError) Reason 

func (e StreamCallExitValidationError) Reason() string

Reason function returns reason value.

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 (m *StreamCallRequest) Validate() error

Validate checks the field values on StreamCallRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 

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 StreamCallRequestValidationError 

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

StreamCallRequestValidationError is the validation error returned by StreamCallRequest.Validate if the designated constraints aren't met.

func (StreamCallRequestValidationError) Cause 

func (e StreamCallRequestValidationError) Cause() error

Cause function returns cause value.

func (StreamCallRequestValidationError) Error 

func (e StreamCallRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCallRequestValidationError) ErrorName 

func (e StreamCallRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCallRequestValidationError) Field 

func (e StreamCallRequestValidationError) Field() string

Field function returns field value.

func (StreamCallRequestValidationError) Key 

func (e StreamCallRequestValidationError) Key() bool

Key function returns key value.

func (StreamCallRequestValidationError) Reason 

func (e StreamCallRequestValidationError) Reason() string

Reason function returns reason value.

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 (m *StreamCallResponse) Validate() error

Validate checks the field values on StreamCallResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 

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 StreamCallResponseValidationError 

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

StreamCallResponseValidationError is the validation error returned by StreamCallResponse.Validate if the designated constraints aren't met.

func (StreamCallResponseValidationError) Cause 

func (e StreamCallResponseValidationError) Cause() error

Cause function returns cause value.

func (StreamCallResponseValidationError) Error 

func (e StreamCallResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCallResponseValidationError) ErrorName 

func (e StreamCallResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCallResponseValidationError) Field 

func (e StreamCallResponseValidationError) Field() string

Field function returns field value.

func (StreamCallResponseValidationError) Key 

func (e StreamCallResponseValidationError) Key() bool

Key function returns key value.

func (StreamCallResponseValidationError) Reason 

func (e StreamCallResponseValidationError) Reason() string

Reason function returns reason value.

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 

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 

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

func (*StreamCallValue) GetAck 

func (m *StreamCallValue) GetAck() *StreamCallAck

func (*StreamCallValue) GetConfig 

func (m *StreamCallValue) GetConfig() *StreamCallConfig

func (*StreamCallValue) GetExit 

func (m *StreamCallValue) GetExit() *StreamCallExit

func (*StreamCallValue) GetUnion 

func (m *StreamCallValue) GetUnion() isStreamCallValue_Union

func (*StreamCallValue) GetValue 

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

func (*StreamCallValue) ProtoMessage 

func (*StreamCallValue) ProtoMessage()

func (*StreamCallValue) Reset 

func (m *StreamCallValue) Reset()

func (*StreamCallValue) String 

func (m *StreamCallValue) String() string

func (*StreamCallValue) Validate 

func (m *StreamCallValue) Validate() error

Validate checks the field values on StreamCallValue with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*StreamCallValue) XXX_DiscardUnknown 

func (m *StreamCallValue) XXX_DiscardUnknown()

func (*StreamCallValue) XXX_Marshal 

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

func (*StreamCallValue) XXX_Merge 

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

func (*StreamCallValue) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamCallValue) XXX_Size 

func (m *StreamCallValue) XXX_Size() int

func (*StreamCallValue) XXX_Unmarshal 

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

type StreamCallValueValidationError 

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

StreamCallValueValidationError is the validation error returned by StreamCallValue.Validate if the designated constraints aren't met.

func (StreamCallValueValidationError) Cause 

func (e StreamCallValueValidationError) Cause() error

Cause function returns cause value.

func (StreamCallValueValidationError) Error 

func (e StreamCallValueValidationError) Error() string

Error satisfies the builtin error interface

func (StreamCallValueValidationError) ErrorName 

func (e StreamCallValueValidationError) ErrorName() string

ErrorName returns error name.

func (StreamCallValueValidationError) Field 

func (e StreamCallValueValidationError) Field() string

Field function returns field value.

func (StreamCallValueValidationError) Key 

func (e StreamCallValueValidationError) Key() bool

Key function returns key value.

func (StreamCallValueValidationError) Reason 

func (e StreamCallValueValidationError) Reason() string

Reason function returns reason value.

type StreamCallValue_Ack 

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

type StreamCallValue_Config 

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

type StreamCallValue_Exit 

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

type StreamCallValue_Value 

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

type StreamFrameKind 

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 

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

func (StreamFrameKind) String 

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 (m *UnaryCallRequest) Validate() error

Validate checks the field values on UnaryCallRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 UnaryCallRequestValidationError 

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

UnaryCallRequestValidationError is the validation error returned by UnaryCallRequest.Validate if the designated constraints aren't met.

func (UnaryCallRequestValidationError) Cause 

func (e UnaryCallRequestValidationError) Cause() error

Cause function returns cause value.

func (UnaryCallRequestValidationError) Error 

func (e UnaryCallRequestValidationError) Error() string

Error satisfies the builtin error interface

func (UnaryCallRequestValidationError) ErrorName 

func (e UnaryCallRequestValidationError) ErrorName() string

ErrorName returns error name.

func (UnaryCallRequestValidationError) Field 

func (e UnaryCallRequestValidationError) Field() string

Field function returns field value.

func (UnaryCallRequestValidationError) Key 

func (e UnaryCallRequestValidationError) Key() bool

Key function returns key value.

func (UnaryCallRequestValidationError) Reason 

func (e UnaryCallRequestValidationError) Reason() string

Reason function returns reason value.

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 (m *UnaryCallResponse) Validate() error

Validate checks the field values on UnaryCallResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

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 UnaryCallResponseValidationError 

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

UnaryCallResponseValidationError is the validation error returned by UnaryCallResponse.Validate if the designated constraints aren't met.

func (UnaryCallResponseValidationError) Cause 

func (e UnaryCallResponseValidationError) Cause() error

Cause function returns cause value.

func (UnaryCallResponseValidationError) Error 

func (e UnaryCallResponseValidationError) Error() string

Error satisfies the builtin error interface

func (UnaryCallResponseValidationError) ErrorName 

func (e UnaryCallResponseValidationError) ErrorName() string

ErrorName returns error name.

func (UnaryCallResponseValidationError) Field 

func (e UnaryCallResponseValidationError) Field() string

Field function returns field value.

func (UnaryCallResponseValidationError) Key 

func (e UnaryCallResponseValidationError) Key() bool

Key function returns key value.

func (UnaryCallResponseValidationError) Reason 

func (e UnaryCallResponseValidationError) Reason() string

Reason function returns reason value.

type UnaryCallValue 

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 

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

func (*UnaryCallValue) GetMethod 

func (m *UnaryCallValue) GetMethod() string

func (*UnaryCallValue) GetSession 

func (m *UnaryCallValue) GetSession() int64

func (*UnaryCallValue) GetValue 

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

func (*UnaryCallValue) ProtoMessage 

func (*UnaryCallValue) ProtoMessage()

func (*UnaryCallValue) Reset 

func (m *UnaryCallValue) Reset()

func (*UnaryCallValue) String 

func (m *UnaryCallValue) String() string

func (*UnaryCallValue) Validate 

func (m *UnaryCallValue) Validate() error

Validate checks the field values on UnaryCallValue with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*UnaryCallValue) XXX_DiscardUnknown 

func (m *UnaryCallValue) XXX_DiscardUnknown()

func (*UnaryCallValue) XXX_Marshal 

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

func (*UnaryCallValue) XXX_Merge 

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

func (*UnaryCallValue) XXX_Size 

func (m *UnaryCallValue) XXX_Size() int

func (*UnaryCallValue) XXX_Unmarshal 

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

type UnaryCallValueValidationError 

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

UnaryCallValueValidationError is the validation error returned by UnaryCallValue.Validate if the designated constraints aren't met.

func (UnaryCallValueValidationError) Cause 

func (e UnaryCallValueValidationError) Cause() error

Cause function returns cause value.

func (UnaryCallValueValidationError) Error 

func (e UnaryCallValueValidationError) Error() string

Error satisfies the builtin error interface

func (UnaryCallValueValidationError) ErrorName 

func (e UnaryCallValueValidationError) ErrorName() string

ErrorName returns error name.

func (UnaryCallValueValidationError) Field 

func (e UnaryCallValueValidationError) Field() string

Field function returns field value.

func (UnaryCallValueValidationError) Key 

func (e UnaryCallValueValidationError) Key() bool

Key function returns key value.

func (UnaryCallValueValidationError) Reason 

func (e UnaryCallValueValidationError) Reason() string

Reason function returns reason value.

type UpStreamFrame 

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 

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

func (*UpStreamFrame) GetError 

func (m *UpStreamFrame) GetError() *ErrorValue

func (*UpStreamFrame) GetKind 

func (m *UpStreamFrame) GetKind() StreamFrameKind

func (*UpStreamFrame) GetStreamCall 

func (m *UpStreamFrame) GetStreamCall() *StreamCallValue

func (*UpStreamFrame) GetUnaryCall 

func (m *UpStreamFrame) GetUnaryCall() *UnaryCallValue

func (*UpStreamFrame) GetUnion 

func (m *UpStreamFrame) GetUnion() isUpStreamFrame_Union

func (*UpStreamFrame) ProtoMessage 

func (*UpStreamFrame) ProtoMessage()

func (*UpStreamFrame) Reset 

func (m *UpStreamFrame) Reset()

func (*UpStreamFrame) String 

func (m *UpStreamFrame) String() string

func (*UpStreamFrame) Validate 

func (m *UpStreamFrame) Validate() error

Validate checks the field values on UpStreamFrame with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*UpStreamFrame) XXX_DiscardUnknown 

func (m *UpStreamFrame) XXX_DiscardUnknown()

func (*UpStreamFrame) XXX_Marshal 

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

func (*UpStreamFrame) XXX_Merge 

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

func (*UpStreamFrame) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*UpStreamFrame) XXX_Size 

func (m *UpStreamFrame) XXX_Size() int

func (*UpStreamFrame) XXX_Unmarshal 

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

type UpStreamFrameValidationError 

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

UpStreamFrameValidationError is the validation error returned by UpStreamFrame.Validate if the designated constraints aren't met.

func (UpStreamFrameValidationError) Cause 

func (e UpStreamFrameValidationError) Cause() error

Cause function returns cause value.

func (UpStreamFrameValidationError) Error 

func (e UpStreamFrameValidationError) Error() string

Error satisfies the builtin error interface

func (UpStreamFrameValidationError) ErrorName 

func (e UpStreamFrameValidationError) ErrorName() string

ErrorName returns error name.

func (UpStreamFrameValidationError) Field 

func (e UpStreamFrameValidationError) Field() string

Field function returns field value.

func (UpStreamFrameValidationError) Key 

func (e UpStreamFrameValidationError) Key() bool

Key function returns key value.

func (UpStreamFrameValidationError) Reason 

func (e UpStreamFrameValidationError) Reason() string

Reason function returns reason value.

type UpStreamFrame_Error 

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

type UpStreamFrame_StreamCall 

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

type UpStreamFrame_UnaryCall 

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.