transport

Documentation

Index

• Constants
• type IdGrpc
  • func (t *IdGrpc) GenerateSnowflakeId(ctx context.Context, req *pb.GenerateSnowflakeIdReq) (*pb.GenerateSnowflakeIdRsp, error)
  • func (t *IdGrpc) Register() error
• type IdGrpcDecoder
  • func (*IdGrpcDecoder) GenerateSnowflakeId(_ context.Context, r any) (any, error)
• type IdGrpcEncoder
  • func (*IdGrpcEncoder) GenerateSnowflakeId(_ context.Context, r any) (any, error)
• type IdHttp
  • func (t *IdHttp) Register() error
• type IdHttpDecoder
  • func (*IdHttpDecoder) GenerateSnowflakeId(_ context.Context, r *http.Request) (any, error)

Constants

const (
	HandlerGenerateSnowflakeId = iota
)

Types

type IdGrpc

type IdGrpc struct {
	pb.UnimplementedIdServiceServer

	Grpc     *grpc.Server         `inject:"application.grpc"`
	Endpoint *endpoint.IdEndpoint `inject:""`
	Decoder  *IdGrpcDecoder       `inject:""`
	Encoder  *IdGrpcEncoder       `inject:""`
	// contains filtered or unexported fields
}

func (*IdGrpc) GenerateSnowflakeId

func (t *IdGrpc) GenerateSnowflakeId(ctx context.Context, req *pb.GenerateSnowflakeIdReq) (*pb.GenerateSnowflakeIdRsp, error)

func (*IdGrpc) Register

func (t *IdGrpc) Register() error

type IdGrpcDecoder

type IdGrpcDecoder struct{}

func (*IdGrpcDecoder) GenerateSnowflakeId

func (*IdGrpcDecoder) GenerateSnowflakeId(_ context.Context, r any) (any, error)

type IdGrpcEncoder

type IdGrpcEncoder struct{}

func (*IdGrpcEncoder) GenerateSnowflakeId

func (*IdGrpcEncoder) GenerateSnowflakeId(_ context.Context, r any) (any, error)

type IdHttp

type IdHttp struct {
	Router   *bone.Router         `inject:"application.router"`
	Endpoint *endpoint.IdEndpoint `inject:""`
	Decoder  *IdHttpDecoder       `inject:""`
}

func (*IdHttp) Register

func (t *IdHttp) Register() error

type IdHttpDecoder

type IdHttpDecoder struct{}

func (*IdHttpDecoder) GenerateSnowflakeId

func (*IdHttpDecoder) GenerateSnowflakeId(_ context.Context, r *http.Request) (any, error)