pb

Documentation

Index

• Variables
• func RegisterSagaBankServiceServer(s grpc.ServiceRegistrar, srv SagaBankServiceServer)
• type SagaBankServiceClient
  • func NewSagaBankServiceClient(cc grpc.ClientConnInterface) SagaBankServiceClient
• type SagaBankServiceServer
• type SagaRequest
  • func (*SagaRequest) Descriptor() ([]byte, []int)
  • func (x *SagaRequest) GetAccount() int32
  • func (x *SagaRequest) GetUserId() int32
  • func (*SagaRequest) ProtoMessage()
  • func (x *SagaRequest) ProtoReflect() protoreflect.Message
  • func (x *SagaRequest) Reset()
  • func (x *SagaRequest) String() string
• type SagaResponse
  • func (*SagaResponse) Descriptor() ([]byte, []int)
  • func (*SagaResponse) ProtoMessage()
  • func (x *SagaResponse) ProtoReflect() protoreflect.Message
  • func (x *SagaResponse) Reset()
  • func (x *SagaResponse) String() string
• type UnimplementedSagaBankServiceServer
  • func (UnimplementedSagaBankServiceServer) In(context.Context, *SagaRequest) (*SagaResponse, error)
  • func (UnimplementedSagaBankServiceServer) Out(context.Context, *SagaRequest) (*SagaResponse, error)
• type UnsafeSagaBankServiceServer

Variables

var File_saga_bank_proto protoreflect.FileDescriptor

var SagaBankService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "bankservice.SagaBankService",
	HandlerType: (*SagaBankServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "In",
			Handler:    _SagaBankService_In_Handler,
		},
		{
			MethodName: "Out",
			Handler:    _SagaBankService_Out_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "saga_bank.proto",
}

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

Functions

func RegisterSagaBankServiceServer

func RegisterSagaBankServiceServer(s grpc.ServiceRegistrar, srv SagaBankServiceServer)

Types

type SagaBankServiceClient

type SagaBankServiceClient interface {
	In(ctx context.Context, in *SagaRequest, opts ...grpc.CallOption) (*SagaResponse, error)
	Out(ctx context.Context, in *SagaRequest, opts ...grpc.CallOption) (*SagaResponse, error)
}

SagaBankServiceClient is the client API for SagaBankService 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 NewSagaBankServiceClient

func NewSagaBankServiceClient(cc grpc.ClientConnInterface) SagaBankServiceClient

type SagaBankServiceServer

type SagaBankServiceServer interface {
	In(context.Context, *SagaRequest) (*SagaResponse, error)
	Out(context.Context, *SagaRequest) (*SagaResponse, error)
	// contains filtered or unexported methods
}

SagaBankServiceServer is the server API for SagaBankService service. All implementations must embed UnimplementedSagaBankServiceServer for forward compatibility

type SagaRequest

type SagaRequest struct {
	UserId  int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Account int32 `protobuf:"varint,2,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*SagaRequest) Descriptor

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

Deprecated: Use SagaRequest.ProtoReflect.Descriptor instead.

func (*SagaRequest) GetAccount

func (x *SagaRequest) GetAccount() int32

func (*SagaRequest) GetUserId

func (x *SagaRequest) GetUserId() int32

func (*SagaRequest) ProtoMessage

func (*SagaRequest) ProtoMessage()

func (*SagaRequest) ProtoReflect

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

func (*SagaRequest) Reset

func (x *SagaRequest) Reset()

func (*SagaRequest) String

func (x *SagaRequest) String() string

type SagaResponse

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

func (*SagaResponse) Descriptor

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

Deprecated: Use SagaResponse.ProtoReflect.Descriptor instead.

func (*SagaResponse) ProtoMessage

func (*SagaResponse) ProtoMessage()

func (*SagaResponse) ProtoReflect

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

func (*SagaResponse) Reset

func (x *SagaResponse) Reset()

func (*SagaResponse) String

func (x *SagaResponse) String() string

type UnimplementedSagaBankServiceServer

type UnimplementedSagaBankServiceServer struct {
}

UnimplementedSagaBankServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSagaBankServiceServer) In

func (UnimplementedSagaBankServiceServer) In(context.Context, *SagaRequest) (*SagaResponse, error)

func (UnimplementedSagaBankServiceServer) Out

func (UnimplementedSagaBankServiceServer) Out(context.Context, *SagaRequest) (*SagaResponse, error)

type UnsafeSagaBankServiceServer

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

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