grpc

Documentation

Index

• type InboundParams
• type Server
  • func NewServer(grpcConfig *config.GrpcConfig, sm *msq.SessionManager) *Server
  • func (s *Server) Invoke(ctx context.Context, inbound *pb.Inbound) (*pb.Outbound, error)
  • func (s *Server) Peek(ctx context.Context, inbound *pb.PeekInbound) (*pb.TransportOutbound, error)
  • func (s *Server) Pop(ctx context.Context, inbound *pb.PopInbound) (*pb.TransportOutbound, error)
  • func (s *Server) Release(ctx context.Context, inbound *pb.ReleaseInbound) (*pb.TransportOutbound, error)
  • func (s *Server) Start(ctx context.Context) error

Types

type InboundParams

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

type Server

type Server struct {
	pb.UnimplementedPrivateTransferTransportServer
	pb.UnimplementedPrivateTransferProtocolServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(grpcConfig *config.GrpcConfig, sm *msq.SessionManager) *Server

func (*Server) Invoke

func (s *Server) Invoke(ctx context.Context, inbound *pb.Inbound) (*pb.Outbound, error)

func (*Server) Peek

func (s *Server) Peek(ctx context.Context, inbound *pb.PeekInbound) (*pb.TransportOutbound, error)

func (*Server) Pop

func (s *Server) Pop(ctx context.Context, inbound *pb.PopInbound) (*pb.TransportOutbound, error)

func (*Server) Release

func (s *Server) Release(ctx context.Context, inbound *pb.ReleaseInbound) (*pb.TransportOutbound, error)

func (*Server) Start

func (s *Server) Start(ctx context.Context) error