server

Documentation

Index

• func New(gCtx global.Context) pb.WaterHoseServiceServer
• type Error
  • func (e Error) Error() string
• type Server
  • func (s *Server) JoinChannel(ctx context.Context, req *pb.JoinChannelRequest) (*pb.JoinChannelResponse, error)
  • func (s *Server) PublishSlaveChannelEvent(ctx context.Context, req *pb.PublishSlaveChannelEventRequest) (*pb.PublishSlaveChannelEventResponse, error)
  • func (s *Server) RegisterSlave(req *pb.RegisterSlaveRequest, srv pb.WaterHoseService_RegisterSlaveServer) error
  • func (s *Server) SlaveJoinLimit(ctx context.Context, req *pb.SlaveJoinLimitRequest) (*pb.SlaveJoinLimitResponse, error)

Functions

func New

func New(gCtx global.Context) pb.WaterHoseServiceServer

Types

type Error

type Error string

const (
	ErrNoLoginData Error = "no login data"
	ErrBadNodeName Error = "bad node name"
)

func (Error) Error

func (e Error) Error() string

type Server

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

func (*Server) JoinChannel

func (s *Server) JoinChannel(ctx context.Context, req *pb.JoinChannelRequest) (*pb.JoinChannelResponse, error)

func (*Server) PublishSlaveChannelEvent

func (s *Server) PublishSlaveChannelEvent(ctx context.Context, req *pb.PublishSlaveChannelEventRequest) (*pb.PublishSlaveChannelEventResponse, error)

func (*Server) RegisterSlave

func (s *Server) RegisterSlave(req *pb.RegisterSlaveRequest, srv pb.WaterHoseService_RegisterSlaveServer) error

func (*Server) SlaveJoinLimit

func (s *Server) SlaveJoinLimit(ctx context.Context, req *pb.SlaveJoinLimitRequest) (*pb.SlaveJoinLimitResponse, error)