component

package
v1.3.0-alpha.5 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2024 License: MIT Imports: 10 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	ModuleService_UnaryCall_FullMethodName  = "/ai.metathings.component.ModuleService/UnaryCall"
	ModuleService_StreamCall_FullMethodName = "/ai.metathings.component.ModuleService/StreamCall"
)

Variables

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

Enum value maps for StreamFrameKind.

View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var File_stream_call_proto protoreflect.FileDescriptor
View Source 
var File_stream_frame_proto protoreflect.FileDescriptor
View Source 
var File_unary_call_proto protoreflect.FileDescriptor
View Source 
var ModuleService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ai.metathings.component.ModuleService",
	HandlerType: (*ModuleServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UnaryCall",
			Handler:    _ModuleService_UnaryCall_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamCall",
			Handler:       _ModuleService_StreamCall_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "service.proto",
}

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

Functions

func RegisterModuleServiceServer 

func RegisterModuleServiceServer(s grpc.ServiceRegistrar, 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 assignable to Union:
	//
	//	*DownStreamFrame_UnaryCall
	//	*DownStreamFrame_StreamCall
	Union isDownStreamFrame_Union `protobuf_oneof:"union"`
	// contains filtered or unexported fields
}

func (*DownStreamFrame) Descriptor deprecated 

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

Deprecated: Use DownStreamFrame.ProtoReflect.Descriptor instead.

func (*DownStreamFrame) GetKind 

func (x *DownStreamFrame) GetKind() StreamFrameKind

func (*DownStreamFrame) GetStreamCall 

func (x *DownStreamFrame) GetStreamCall() *OpStreamCallValue

func (*DownStreamFrame) GetUnaryCall 

func (x *DownStreamFrame) GetUnaryCall() *OpUnaryCallValue

func (*DownStreamFrame) GetUnion 

func (m *DownStreamFrame) GetUnion() isDownStreamFrame_Union

func (*DownStreamFrame) ProtoMessage 

func (*DownStreamFrame) ProtoMessage()

func (*DownStreamFrame) ProtoReflect added in v1.2.14 

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

func (*DownStreamFrame) Reset 

func (x *DownStreamFrame) Reset()

func (*DownStreamFrame) String 

func (x *DownStreamFrame) String() string

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"`
	// contains filtered or unexported fields
}

func (*ErrorValue) Descriptor deprecated 

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

Deprecated: Use ErrorValue.ProtoReflect.Descriptor instead.

func (*ErrorValue) GetCode 

func (x *ErrorValue) GetCode() int64

func (*ErrorValue) GetMessage 

func (x *ErrorValue) GetMessage() string

func (*ErrorValue) ProtoMessage 

func (*ErrorValue) ProtoMessage()

func (*ErrorValue) ProtoReflect added in v1.2.14 

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

func (*ErrorValue) Reset 

func (x *ErrorValue) Reset()

func (*ErrorValue) String 

func (x *ErrorValue) String() string

type ModuleServiceClient 

type ModuleServiceClient interface {
	UnaryCall(ctx context.Context, in *UnaryCallRequest, opts ...grpc.CallOption) (*UnaryCallResponse, error)
	StreamCall(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamCallRequest, StreamCallResponse], error)
}

ModuleServiceClient is the client API for ModuleService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewModuleServiceClient 

func NewModuleServiceClient(cc grpc.ClientConnInterface) ModuleServiceClient

type ModuleServiceServer 

type ModuleServiceServer interface {
	UnaryCall(context.Context, *UnaryCallRequest) (*UnaryCallResponse, error)
	StreamCall(grpc.BidiStreamingServer[StreamCallRequest, StreamCallResponse]) error
	// contains filtered or unexported methods
}

ModuleServiceServer is the server API for ModuleService service. All implementations must embed UnimplementedModuleServiceServer for forward compatibility.

type ModuleService_StreamCallClient 

type ModuleService_StreamCallClient = grpc.BidiStreamingClient[StreamCallRequest, StreamCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ModuleService_StreamCallServer 

type ModuleService_StreamCallServer = grpc.BidiStreamingServer[StreamCallRequest, StreamCallResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type OpStreamCallAck 

type OpStreamCallAck struct {
	Value *wrapperspb.Int64Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*OpStreamCallAck) Descriptor deprecated 

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

Deprecated: Use OpStreamCallAck.ProtoReflect.Descriptor instead.

func (*OpStreamCallAck) GetValue 

func (x *OpStreamCallAck) GetValue() *wrapperspb.Int64Value

func (*OpStreamCallAck) ProtoMessage 

func (*OpStreamCallAck) ProtoMessage()

func (*OpStreamCallAck) ProtoReflect added in v1.2.14 

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

func (*OpStreamCallAck) Reset 

func (x *OpStreamCallAck) Reset()

func (*OpStreamCallAck) String 

func (x *OpStreamCallAck) String() string

type OpStreamCallConfig 

type OpStreamCallConfig struct {
	Session *wrapperspb.Int64Value  `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Method  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Ack     *wrapperspb.Int64Value  `protobuf:"bytes,3,opt,name=ack,proto3" json:"ack,omitempty"`
	// contains filtered or unexported fields
}

func (*OpStreamCallConfig) Descriptor deprecated 

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

Deprecated: Use OpStreamCallConfig.ProtoReflect.Descriptor instead.

func (*OpStreamCallConfig) GetAck 

func (x *OpStreamCallConfig) GetAck() *wrapperspb.Int64Value

func (*OpStreamCallConfig) GetMethod 

func (x *OpStreamCallConfig) GetMethod() *wrapperspb.StringValue

func (*OpStreamCallConfig) GetSession 

func (x *OpStreamCallConfig) GetSession() *wrapperspb.Int64Value

func (*OpStreamCallConfig) ProtoMessage 

func (*OpStreamCallConfig) ProtoMessage()

func (*OpStreamCallConfig) ProtoReflect added in v1.2.14 

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

func (*OpStreamCallConfig) Reset 

func (x *OpStreamCallConfig) Reset()

func (*OpStreamCallConfig) String 

func (x *OpStreamCallConfig) String() string

type OpStreamCallExit 

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

func (*OpStreamCallExit) Descriptor deprecated 

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

Deprecated: Use OpStreamCallExit.ProtoReflect.Descriptor instead.

func (*OpStreamCallExit) ProtoMessage 

func (*OpStreamCallExit) ProtoMessage()

func (*OpStreamCallExit) ProtoReflect added in v1.2.14 

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

func (*OpStreamCallExit) Reset 

func (x *OpStreamCallExit) Reset()

func (*OpStreamCallExit) String 

func (x *OpStreamCallExit) String() string

type OpStreamCallValue 

type OpStreamCallValue struct {

	// Types that are assignable to Union:
	//
	//	*OpStreamCallValue_Value
	//	*OpStreamCallValue_Config
	//	*OpStreamCallValue_Ack
	//	*OpStreamCallValue_Exit
	Union isOpStreamCallValue_Union `protobuf_oneof:"union"`
	// contains filtered or unexported fields
}

func (*OpStreamCallValue) Descriptor deprecated 

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

Deprecated: Use OpStreamCallValue.ProtoReflect.Descriptor instead.

func (*OpStreamCallValue) GetAck 

func (x *OpStreamCallValue) GetAck() *OpStreamCallAck

func (*OpStreamCallValue) GetConfig 

func (x *OpStreamCallValue) GetConfig() *OpStreamCallConfig

func (*OpStreamCallValue) GetExit 

func (x *OpStreamCallValue) GetExit() *OpStreamCallExit

func (*OpStreamCallValue) GetUnion 

func (m *OpStreamCallValue) GetUnion() isOpStreamCallValue_Union

func (*OpStreamCallValue) GetValue 

func (x *OpStreamCallValue) GetValue() *anypb.Any

func (*OpStreamCallValue) ProtoMessage 

func (*OpStreamCallValue) ProtoMessage()

func (*OpStreamCallValue) ProtoReflect added in v1.2.14 

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

func (*OpStreamCallValue) Reset 

func (x *OpStreamCallValue) Reset()

func (*OpStreamCallValue) String 

func (x *OpStreamCallValue) String() string

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 *anypb.Any `protobuf:"bytes,1,opt,name=value,proto3,oneof"`
}

type OpUnaryCallValue 

type OpUnaryCallValue struct {
	Session *wrapperspb.Int64Value  `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Method  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Value   *anypb.Any              `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*OpUnaryCallValue) Descriptor deprecated 

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

Deprecated: Use OpUnaryCallValue.ProtoReflect.Descriptor instead.

func (*OpUnaryCallValue) GetMethod 

func (x *OpUnaryCallValue) GetMethod() *wrapperspb.StringValue

func (*OpUnaryCallValue) GetSession 

func (x *OpUnaryCallValue) GetSession() *wrapperspb.Int64Value

func (*OpUnaryCallValue) GetValue 

func (x *OpUnaryCallValue) GetValue() *anypb.Any

func (*OpUnaryCallValue) ProtoMessage 

func (*OpUnaryCallValue) ProtoMessage()

func (*OpUnaryCallValue) ProtoReflect added in v1.2.14 

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

func (*OpUnaryCallValue) Reset 

func (x *OpUnaryCallValue) Reset()

func (*OpUnaryCallValue) String 

func (x *OpUnaryCallValue) String() string

type StreamCallAck 

type StreamCallAck struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCallAck) Descriptor deprecated 

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

Deprecated: Use StreamCallAck.ProtoReflect.Descriptor instead.

func (*StreamCallAck) GetValue 

func (x *StreamCallAck) GetValue() int64

func (*StreamCallAck) ProtoMessage 

func (*StreamCallAck) ProtoMessage()

func (*StreamCallAck) ProtoReflect added in v1.2.14 

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

func (*StreamCallAck) Reset 

func (x *StreamCallAck) Reset()

func (*StreamCallAck) String 

func (x *StreamCallAck) String() string

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"`
	// contains filtered or unexported fields
}

func (*StreamCallConfig) Descriptor deprecated 

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

Deprecated: Use StreamCallConfig.ProtoReflect.Descriptor instead.

func (*StreamCallConfig) GetAck 

func (x *StreamCallConfig) GetAck() int64

func (*StreamCallConfig) GetMethod 

func (x *StreamCallConfig) GetMethod() string

func (*StreamCallConfig) GetSession 

func (x *StreamCallConfig) GetSession() int64

func (*StreamCallConfig) ProtoMessage 

func (*StreamCallConfig) ProtoMessage()

func (*StreamCallConfig) ProtoReflect added in v1.2.14 

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

func (*StreamCallConfig) Reset 

func (x *StreamCallConfig) Reset()

func (*StreamCallConfig) String 

func (x *StreamCallConfig) String() string

type StreamCallConfigRequest 

type StreamCallConfigRequest struct {
	Method *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCallConfigRequest) Descriptor deprecated 

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

Deprecated: Use StreamCallConfigRequest.ProtoReflect.Descriptor instead.

func (*StreamCallConfigRequest) GetMethod 

func (x *StreamCallConfigRequest) GetMethod() *wrapperspb.StringValue

func (*StreamCallConfigRequest) ProtoMessage 

func (*StreamCallConfigRequest) ProtoMessage()

func (*StreamCallConfigRequest) ProtoReflect added in v1.2.14 

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

func (*StreamCallConfigRequest) Reset 

func (x *StreamCallConfigRequest) Reset()

func (*StreamCallConfigRequest) String 

func (x *StreamCallConfigRequest) String() string

type StreamCallConfigResponse 

type StreamCallConfigResponse struct {
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCallConfigResponse) Descriptor deprecated 

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

Deprecated: Use StreamCallConfigResponse.ProtoReflect.Descriptor instead.

func (*StreamCallConfigResponse) GetMethod 

func (x *StreamCallConfigResponse) GetMethod() string

func (*StreamCallConfigResponse) ProtoMessage 

func (*StreamCallConfigResponse) ProtoMessage()

func (*StreamCallConfigResponse) ProtoReflect added in v1.2.14 

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

func (*StreamCallConfigResponse) Reset 

func (x *StreamCallConfigResponse) Reset()

func (*StreamCallConfigResponse) String 

func (x *StreamCallConfigResponse) String() string

type StreamCallDataRequest 

type StreamCallDataRequest struct {
	Value *anypb.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCallDataRequest) Descriptor deprecated 

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

Deprecated: Use StreamCallDataRequest.ProtoReflect.Descriptor instead.

func (*StreamCallDataRequest) GetValue 

func (x *StreamCallDataRequest) GetValue() *anypb.Any

func (*StreamCallDataRequest) ProtoMessage 

func (*StreamCallDataRequest) ProtoMessage()

func (*StreamCallDataRequest) ProtoReflect added in v1.2.14 

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

func (*StreamCallDataRequest) Reset 

func (x *StreamCallDataRequest) Reset()

func (*StreamCallDataRequest) String 

func (x *StreamCallDataRequest) String() string

type StreamCallDataResponse 

type StreamCallDataResponse struct {
	Value *anypb.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCallDataResponse) Descriptor deprecated 

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

Deprecated: Use StreamCallDataResponse.ProtoReflect.Descriptor instead.

func (*StreamCallDataResponse) GetValue 

func (x *StreamCallDataResponse) GetValue() *anypb.Any

func (*StreamCallDataResponse) ProtoMessage 

func (*StreamCallDataResponse) ProtoMessage()

func (*StreamCallDataResponse) ProtoReflect added in v1.2.14 

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

func (*StreamCallDataResponse) Reset 

func (x *StreamCallDataResponse) Reset()

func (*StreamCallDataResponse) String 

func (x *StreamCallDataResponse) String() string

type StreamCallExit 

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

func (*StreamCallExit) Descriptor deprecated 

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

Deprecated: Use StreamCallExit.ProtoReflect.Descriptor instead.

func (*StreamCallExit) ProtoMessage 

func (*StreamCallExit) ProtoMessage()

func (*StreamCallExit) ProtoReflect added in v1.2.14 

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

func (*StreamCallExit) Reset 

func (x *StreamCallExit) Reset()

func (*StreamCallExit) String 

func (x *StreamCallExit) String() string

type StreamCallRequest 

type StreamCallRequest struct {

	// Types that are assignable to Request:
	//
	//	*StreamCallRequest_Config
	//	*StreamCallRequest_Data
	Request isStreamCallRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*StreamCallRequest) Descriptor deprecated 

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

Deprecated: Use StreamCallRequest.ProtoReflect.Descriptor instead.

func (*StreamCallRequest) GetConfig 

func (x *StreamCallRequest) GetConfig() *StreamCallConfigRequest

func (*StreamCallRequest) GetData 

func (x *StreamCallRequest) GetData() *StreamCallDataRequest

func (*StreamCallRequest) GetRequest 

func (m *StreamCallRequest) GetRequest() isStreamCallRequest_Request

func (*StreamCallRequest) ProtoMessage 

func (*StreamCallRequest) ProtoMessage()

func (*StreamCallRequest) ProtoReflect added in v1.2.14 

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

func (*StreamCallRequest) Reset 

func (x *StreamCallRequest) Reset()

func (*StreamCallRequest) String 

func (x *StreamCallRequest) String() string

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 assignable to Response:
	//
	//	*StreamCallResponse_Config
	//	*StreamCallResponse_Data
	Response isStreamCallResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*StreamCallResponse) Descriptor deprecated 

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

Deprecated: Use StreamCallResponse.ProtoReflect.Descriptor instead.

func (*StreamCallResponse) GetConfig 

func (x *StreamCallResponse) GetConfig() *StreamCallConfigResponse

func (*StreamCallResponse) GetData 

func (x *StreamCallResponse) GetData() *StreamCallDataResponse

func (*StreamCallResponse) GetResponse 

func (m *StreamCallResponse) GetResponse() isStreamCallResponse_Response

func (*StreamCallResponse) ProtoMessage 

func (*StreamCallResponse) ProtoMessage()

func (*StreamCallResponse) ProtoReflect added in v1.2.14 

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

func (*StreamCallResponse) Reset 

func (x *StreamCallResponse) Reset()

func (*StreamCallResponse) String 

func (x *StreamCallResponse) String() string

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 assignable to Union:
	//
	//	*StreamCallValue_Value
	//	*StreamCallValue_Config
	//	*StreamCallValue_Ack
	//	*StreamCallValue_Exit
	Union isStreamCallValue_Union `protobuf_oneof:"union"`
	// contains filtered or unexported fields
}

func (*StreamCallValue) Descriptor deprecated 

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

Deprecated: Use StreamCallValue.ProtoReflect.Descriptor instead.

func (*StreamCallValue) GetAck 

func (x *StreamCallValue) GetAck() *StreamCallAck

func (*StreamCallValue) GetConfig 

func (x *StreamCallValue) GetConfig() *StreamCallConfig

func (*StreamCallValue) GetExit 

func (x *StreamCallValue) GetExit() *StreamCallExit

func (*StreamCallValue) GetUnion 

func (m *StreamCallValue) GetUnion() isStreamCallValue_Union

func (*StreamCallValue) GetValue 

func (x *StreamCallValue) GetValue() *anypb.Any

func (*StreamCallValue) ProtoMessage 

func (*StreamCallValue) ProtoMessage()

func (*StreamCallValue) ProtoReflect added in v1.2.14 

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

func (*StreamCallValue) Reset 

func (x *StreamCallValue) Reset()

func (*StreamCallValue) String 

func (x *StreamCallValue) String() string

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 *anypb.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) Descriptor added in v1.2.14 

func (StreamFrameKind) Descriptor() protoreflect.EnumDescriptor

func (StreamFrameKind) Enum added in v1.2.14 

func (x StreamFrameKind) Enum() *StreamFrameKind

func (StreamFrameKind) EnumDescriptor deprecated 

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

Deprecated: Use StreamFrameKind.Descriptor instead.

func (StreamFrameKind) Number added in v1.2.14 

func (x StreamFrameKind) Number() protoreflect.EnumNumber

func (StreamFrameKind) String 

func (x StreamFrameKind) String() string

func (StreamFrameKind) Type added in v1.2.14 

func (StreamFrameKind) Type() protoreflect.EnumType

type UnaryCallRequest 

type UnaryCallRequest struct {
	Method *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Value  *anypb.Any              `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UnaryCallRequest) Descriptor deprecated 

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

Deprecated: Use UnaryCallRequest.ProtoReflect.Descriptor instead.

func (*UnaryCallRequest) GetMethod 

func (x *UnaryCallRequest) GetMethod() *wrapperspb.StringValue

func (*UnaryCallRequest) GetValue 

func (x *UnaryCallRequest) GetValue() *anypb.Any

func (*UnaryCallRequest) ProtoMessage 

func (*UnaryCallRequest) ProtoMessage()

func (*UnaryCallRequest) ProtoReflect added in v1.2.14 

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

func (*UnaryCallRequest) Reset 

func (x *UnaryCallRequest) Reset()

func (*UnaryCallRequest) String 

func (x *UnaryCallRequest) String() string

type UnaryCallResponse 

type UnaryCallResponse struct {
	Method string     `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Value  *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UnaryCallResponse) Descriptor deprecated 

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

Deprecated: Use UnaryCallResponse.ProtoReflect.Descriptor instead.

func (*UnaryCallResponse) GetMethod 

func (x *UnaryCallResponse) GetMethod() string

func (*UnaryCallResponse) GetValue 

func (x *UnaryCallResponse) GetValue() *anypb.Any

func (*UnaryCallResponse) ProtoMessage 

func (*UnaryCallResponse) ProtoMessage()

func (*UnaryCallResponse) ProtoReflect added in v1.2.14 

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

func (*UnaryCallResponse) Reset 

func (x *UnaryCallResponse) Reset()

func (*UnaryCallResponse) String 

func (x *UnaryCallResponse) String() string

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   *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UnaryCallValue) Descriptor deprecated 

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

Deprecated: Use UnaryCallValue.ProtoReflect.Descriptor instead.

func (*UnaryCallValue) GetMethod 

func (x *UnaryCallValue) GetMethod() string

func (*UnaryCallValue) GetSession 

func (x *UnaryCallValue) GetSession() int64

func (*UnaryCallValue) GetValue 

func (x *UnaryCallValue) GetValue() *anypb.Any

func (*UnaryCallValue) ProtoMessage 

func (*UnaryCallValue) ProtoMessage()

func (*UnaryCallValue) ProtoReflect added in v1.2.14 

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

func (*UnaryCallValue) Reset 

func (x *UnaryCallValue) Reset()

func (*UnaryCallValue) String 

func (x *UnaryCallValue) String() string

type UnimplementedModuleServiceServer added in v1.2.14 

type UnimplementedModuleServiceServer struct{}

UnimplementedModuleServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedModuleServiceServer) StreamCall added in v1.2.14 

func (UnimplementedModuleServiceServer) StreamCall(grpc.BidiStreamingServer[StreamCallRequest, StreamCallResponse]) error

func (UnimplementedModuleServiceServer) UnaryCall added in v1.2.14 

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

type UnsafeModuleServiceServer 

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

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

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 assignable to Union:
	//
	//	*UpStreamFrame_UnaryCall
	//	*UpStreamFrame_StreamCall
	//	*UpStreamFrame_Error
	Union isUpStreamFrame_Union `protobuf_oneof:"union"`
	// contains filtered or unexported fields
}

func (*UpStreamFrame) Descriptor deprecated 

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

Deprecated: Use UpStreamFrame.ProtoReflect.Descriptor instead.

func (*UpStreamFrame) GetError 

func (x *UpStreamFrame) GetError() *ErrorValue

func (*UpStreamFrame) GetKind 

func (x *UpStreamFrame) GetKind() StreamFrameKind

func (*UpStreamFrame) GetStreamCall 

func (x *UpStreamFrame) GetStreamCall() *StreamCallValue

func (*UpStreamFrame) GetUnaryCall 

func (x *UpStreamFrame) GetUnaryCall() *UnaryCallValue

func (*UpStreamFrame) GetUnion 

func (m *UpStreamFrame) GetUnion() isUpStreamFrame_Union

func (*UpStreamFrame) ProtoMessage 

func (*UpStreamFrame) ProtoMessage()

func (*UpStreamFrame) ProtoReflect added in v1.2.14 

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

func (*UpStreamFrame) Reset 

func (x *UpStreamFrame) Reset()

func (*UpStreamFrame) String 

func (x *UpStreamFrame) String() string

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.