component

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
}

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

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

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
}

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

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

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

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

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

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
}

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

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
}

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

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

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

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

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
}

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

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
}

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

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

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

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

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

type StreamCallRequest struct {

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

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

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

type StreamCallResponse struct {

	// Types that are assignable to Response:
	//	*StreamCallResponse_Config
	//	*StreamCallResponse_Data
	Response isStreamCallResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

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

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

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
}

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

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

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

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

type StreamFrameKind int32

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
}

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
}

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
}

type UnimplementedModuleServiceServer struct {
}

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
}

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

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

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