Documentation
¶
Index ¶
- type InboundParams
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) 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)
Source Files
Click to show internal directories.
Click to hide internal directories.