Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterProtoServiceServer(s grpc.ServiceRegistrar, srv ProtoServiceServer)
- type DemoCommandReply
- type DemoCommandRequest
- func (*DemoCommandRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DemoCommandRequest) GetAge() int32
- func (x *DemoCommandRequest) GetName() string
- func (x *DemoCommandRequest) GetSalary() float64
- func (x *DemoCommandRequest) GetToken() string
- func (*DemoCommandRequest) ProtoMessage()
- func (x *DemoCommandRequest) ProtoReflect() protoreflect.Message
- func (x *DemoCommandRequest) Reset()
- func (x *DemoCommandRequest) String() string
- type DemoDefaultReply
- type DemoDefaultRequest
- func (*DemoDefaultRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DemoDefaultRequest) GetAge() int32
- func (x *DemoDefaultRequest) GetName() string
- func (x *DemoDefaultRequest) GetSalary() float64
- func (x *DemoDefaultRequest) GetToken() string
- func (*DemoDefaultRequest) ProtoMessage()
- func (x *DemoDefaultRequest) ProtoReflect() protoreflect.Message
- func (x *DemoDefaultRequest) Reset()
- func (x *DemoDefaultRequest) String() string
- type DemoQueryReply
- type DemoQueryRequest
- func (*DemoQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DemoQueryRequest) GetAge() int32
- func (x *DemoQueryRequest) GetName() string
- func (x *DemoQueryRequest) GetSalary() float64
- func (x *DemoQueryRequest) GetToken() string
- func (*DemoQueryRequest) ProtoMessage()
- func (x *DemoQueryRequest) ProtoReflect() protoreflect.Message
- func (x *DemoQueryRequest) Reset()
- func (x *DemoQueryRequest) String() string
- type ProtoServiceClient
- type ProtoServiceServer
- type UnimplementedProtoServiceServer
- func (UnimplementedProtoServiceServer) DemoCommand(context.Context, *DemoCommandRequest) (*DemoCommandReply, error)
- func (UnimplementedProtoServiceServer) DemoDefault(context.Context, *DemoDefaultRequest) (*DemoDefaultReply, error)
- func (UnimplementedProtoServiceServer) DemoQuery(context.Context, *DemoQueryRequest) (*DemoQueryReply, error)
- type UnsafeProtoServiceServer
Constants ¶
const ( ProtoService_DemoCommand_FullMethodName = "/pb.ProtoService/DemoCommand" ProtoService_DemoQuery_FullMethodName = "/pb.ProtoService/DemoQuery" ProtoService_DemoDefault_FullMethodName = "/pb.ProtoService/DemoDefault" )
Variables ¶
var File_cqrs_cmd_example_api_pb_protoservice_proto protoreflect.FileDescriptor
var ProtoService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pb.ProtoService", HandlerType: (*ProtoServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "DemoCommand", Handler: _ProtoService_DemoCommand_Handler, }, { MethodName: "DemoQuery", Handler: _ProtoService_DemoQuery_Handler, }, { MethodName: "DemoDefault", Handler: _ProtoService_DemoDefault_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cqrs/cmd/example/api/pb/protoservice.proto", }
ProtoService_ServiceDesc is the grpc.ServiceDesc for ProtoService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterProtoServiceServer ¶
func RegisterProtoServiceServer(s grpc.ServiceRegistrar, srv ProtoServiceServer)
Types ¶
type DemoCommandReply ¶
type DemoCommandReply struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*DemoCommandReply) Descriptor
deprecated
func (*DemoCommandReply) Descriptor() ([]byte, []int)
Deprecated: Use DemoCommandReply.ProtoReflect.Descriptor instead.
func (*DemoCommandReply) GetMessage ¶
func (x *DemoCommandReply) GetMessage() string
func (*DemoCommandReply) ProtoMessage ¶
func (*DemoCommandReply) ProtoMessage()
func (*DemoCommandReply) ProtoReflect ¶
func (x *DemoCommandReply) ProtoReflect() protoreflect.Message
func (*DemoCommandReply) Reset ¶
func (x *DemoCommandReply) Reset()
func (*DemoCommandReply) String ¶
func (x *DemoCommandReply) String() string
type DemoCommandRequest ¶
type DemoCommandRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Age int32 `protobuf:"varint,2,opt,name=age,proto3" json:"age,omitempty"` Salary float64 `protobuf:"fixed64,3,opt,name=salary,proto3" json:"salary,omitempty"` Token string `protobuf:"bytes,4,opt,name=Token,proto3" json:"Token,omitempty"` // contains filtered or unexported fields }
func (*DemoCommandRequest) Descriptor
deprecated
func (*DemoCommandRequest) Descriptor() ([]byte, []int)
Deprecated: Use DemoCommandRequest.ProtoReflect.Descriptor instead.
func (*DemoCommandRequest) GetAge ¶
func (x *DemoCommandRequest) GetAge() int32
func (*DemoCommandRequest) GetName ¶
func (x *DemoCommandRequest) GetName() string
func (*DemoCommandRequest) GetSalary ¶
func (x *DemoCommandRequest) GetSalary() float64
func (*DemoCommandRequest) GetToken ¶
func (x *DemoCommandRequest) GetToken() string
func (*DemoCommandRequest) ProtoMessage ¶
func (*DemoCommandRequest) ProtoMessage()
func (*DemoCommandRequest) ProtoReflect ¶
func (x *DemoCommandRequest) ProtoReflect() protoreflect.Message
func (*DemoCommandRequest) Reset ¶
func (x *DemoCommandRequest) Reset()
func (*DemoCommandRequest) String ¶
func (x *DemoCommandRequest) String() string
type DemoDefaultReply ¶
type DemoDefaultReply struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*DemoDefaultReply) Descriptor
deprecated
func (*DemoDefaultReply) Descriptor() ([]byte, []int)
Deprecated: Use DemoDefaultReply.ProtoReflect.Descriptor instead.
func (*DemoDefaultReply) GetMessage ¶
func (x *DemoDefaultReply) GetMessage() string
func (*DemoDefaultReply) ProtoMessage ¶
func (*DemoDefaultReply) ProtoMessage()
func (*DemoDefaultReply) ProtoReflect ¶
func (x *DemoDefaultReply) ProtoReflect() protoreflect.Message
func (*DemoDefaultReply) Reset ¶
func (x *DemoDefaultReply) Reset()
func (*DemoDefaultReply) String ¶
func (x *DemoDefaultReply) String() string
type DemoDefaultRequest ¶
type DemoDefaultRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Age int32 `protobuf:"varint,2,opt,name=age,proto3" json:"age,omitempty"` Salary float64 `protobuf:"fixed64,3,opt,name=salary,proto3" json:"salary,omitempty"` Token string `protobuf:"bytes,4,opt,name=Token,proto3" json:"Token,omitempty"` // contains filtered or unexported fields }
func (*DemoDefaultRequest) Descriptor
deprecated
func (*DemoDefaultRequest) Descriptor() ([]byte, []int)
Deprecated: Use DemoDefaultRequest.ProtoReflect.Descriptor instead.
func (*DemoDefaultRequest) GetAge ¶
func (x *DemoDefaultRequest) GetAge() int32
func (*DemoDefaultRequest) GetName ¶
func (x *DemoDefaultRequest) GetName() string
func (*DemoDefaultRequest) GetSalary ¶
func (x *DemoDefaultRequest) GetSalary() float64
func (*DemoDefaultRequest) GetToken ¶
func (x *DemoDefaultRequest) GetToken() string
func (*DemoDefaultRequest) ProtoMessage ¶
func (*DemoDefaultRequest) ProtoMessage()
func (*DemoDefaultRequest) ProtoReflect ¶
func (x *DemoDefaultRequest) ProtoReflect() protoreflect.Message
func (*DemoDefaultRequest) Reset ¶
func (x *DemoDefaultRequest) Reset()
func (*DemoDefaultRequest) String ¶
func (x *DemoDefaultRequest) String() string
type DemoQueryReply ¶
type DemoQueryReply struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*DemoQueryReply) Descriptor
deprecated
func (*DemoQueryReply) Descriptor() ([]byte, []int)
Deprecated: Use DemoQueryReply.ProtoReflect.Descriptor instead.
func (*DemoQueryReply) GetMessage ¶
func (x *DemoQueryReply) GetMessage() string
func (*DemoQueryReply) ProtoMessage ¶
func (*DemoQueryReply) ProtoMessage()
func (*DemoQueryReply) ProtoReflect ¶
func (x *DemoQueryReply) ProtoReflect() protoreflect.Message
func (*DemoQueryReply) Reset ¶
func (x *DemoQueryReply) Reset()
func (*DemoQueryReply) String ¶
func (x *DemoQueryReply) String() string
type DemoQueryRequest ¶
type DemoQueryRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Age int32 `protobuf:"varint,2,opt,name=age,proto3" json:"age,omitempty"` Salary float64 `protobuf:"fixed64,3,opt,name=salary,proto3" json:"salary,omitempty"` Token string `protobuf:"bytes,4,opt,name=Token,proto3" json:"Token,omitempty"` // contains filtered or unexported fields }
func (*DemoQueryRequest) Descriptor
deprecated
func (*DemoQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use DemoQueryRequest.ProtoReflect.Descriptor instead.
func (*DemoQueryRequest) GetAge ¶
func (x *DemoQueryRequest) GetAge() int32
func (*DemoQueryRequest) GetName ¶
func (x *DemoQueryRequest) GetName() string
func (*DemoQueryRequest) GetSalary ¶
func (x *DemoQueryRequest) GetSalary() float64
func (*DemoQueryRequest) GetToken ¶
func (x *DemoQueryRequest) GetToken() string
func (*DemoQueryRequest) ProtoMessage ¶
func (*DemoQueryRequest) ProtoMessage()
func (*DemoQueryRequest) ProtoReflect ¶
func (x *DemoQueryRequest) ProtoReflect() protoreflect.Message
func (*DemoQueryRequest) Reset ¶
func (x *DemoQueryRequest) Reset()
func (*DemoQueryRequest) String ¶
func (x *DemoQueryRequest) String() string
type ProtoServiceClient ¶
type ProtoServiceClient interface { // @CQRS @Command DemoCommand(ctx context.Context, in *DemoCommandRequest, opts ...grpc.CallOption) (*DemoCommandReply, error) // @CQRS @Query DemoQuery(ctx context.Context, in *DemoQueryRequest, opts ...grpc.CallOption) (*DemoQueryReply, error) DemoDefault(ctx context.Context, in *DemoDefaultRequest, opts ...grpc.CallOption) (*DemoDefaultReply, error) }
ProtoServiceClient is the client API for ProtoService 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 NewProtoServiceClient ¶
func NewProtoServiceClient(cc grpc.ClientConnInterface) ProtoServiceClient
type ProtoServiceServer ¶
type ProtoServiceServer interface { // @CQRS @Command DemoCommand(context.Context, *DemoCommandRequest) (*DemoCommandReply, error) // @CQRS @Query DemoQuery(context.Context, *DemoQueryRequest) (*DemoQueryReply, error) DemoDefault(context.Context, *DemoDefaultRequest) (*DemoDefaultReply, error) // contains filtered or unexported methods }
ProtoServiceServer is the server API for ProtoService service. All implementations must embed UnimplementedProtoServiceServer for forward compatibility
type UnimplementedProtoServiceServer ¶
type UnimplementedProtoServiceServer struct { }
UnimplementedProtoServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedProtoServiceServer) DemoCommand ¶
func (UnimplementedProtoServiceServer) DemoCommand(context.Context, *DemoCommandRequest) (*DemoCommandReply, error)
func (UnimplementedProtoServiceServer) DemoDefault ¶
func (UnimplementedProtoServiceServer) DemoDefault(context.Context, *DemoDefaultRequest) (*DemoDefaultReply, error)
func (UnimplementedProtoServiceServer) DemoQuery ¶
func (UnimplementedProtoServiceServer) DemoQuery(context.Context, *DemoQueryRequest) (*DemoQueryReply, error)
type UnsafeProtoServiceServer ¶
type UnsafeProtoServiceServer interface {
// contains filtered or unexported methods
}
UnsafeProtoServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProtoServiceServer will result in compilation errors.