server

Documentation

Index

• type Server
  • func New(conf config.Config) *Server
  • func (s *Server) Context() context.Context
  • func (s *Server) GetBuilder() *resource.Builder
  • func (s *Server) GetCache() *cache.Cache
  • func (s *Server) GetClientMgr() *manager.ClientManager
  • func (s *Server) GetConfig() *config.Config
  • func (s *Server) GetCrawler() *util.Crawler
  • func (s *Server) GetDB() *pg.DB
  • func (s *Server) GetHandlerMgr() *manager.HandlerManager
  • func (s *Server) GetJWT() *util.JWT
  • func (s *Server) GetRedis() *redis.Client
  • func (s *Server) GetRepos() *repository.Repositories
  • func (s *Server) GetRoomMgr() *manager.RoomManager
  • func (s *Server) GetSessionMgr() *manager.SessionManager
  • func (s *Server) GetSubscriptionMgr() *dispatcher.SubscriptionManager
  • func (s *Server) NodeId() string
  • func (s *Server) SetCurrentItem(ctx context.Context, req *gatewaypb.SetCurrentItemRequest) (*gatewaypb.SetCurrentItemResponse, error)
  • func (s *Server) Start() error

Types

type Server

type Server struct {
	gatewaypb.UnimplementedGatewayServiceServer
	config.Config
	pubsub.Dispatcher
	// contains filtered or unexported fields
}

func New

func New(conf config.Config) *Server

func (*Server) Context

func (s *Server) Context() context.Context

func (*Server) GetBuilder

func (s *Server) GetBuilder() *resource.Builder

func (*Server) GetCache

func (s *Server) GetCache() *cache.Cache

func (*Server) GetClientMgr

func (s *Server) GetClientMgr() *manager.ClientManager

func (*Server) GetConfig

func (s *Server) GetConfig() *config.Config

func (*Server) GetCrawler

func (s *Server) GetCrawler() *util.Crawler

func (*Server) GetDB

func (s *Server) GetDB() *pg.DB

func (*Server) GetHandlerMgr

func (s *Server) GetHandlerMgr() *manager.HandlerManager

func (*Server) GetJWT

func (s *Server) GetJWT() *util.JWT

func (*Server) GetRedis

func (s *Server) GetRedis() *redis.Client

func (*Server) GetRepos

func (s *Server) GetRepos() *repository.Repositories

func (*Server) GetRoomMgr

func (s *Server) GetRoomMgr() *manager.RoomManager

func (*Server) GetSessionMgr

func (s *Server) GetSessionMgr() *manager.SessionManager

func (*Server) GetSubscriptionMgr

func (s *Server) GetSubscriptionMgr() *dispatcher.SubscriptionManager

func (*Server) NodeId

func (s *Server) NodeId() string

func (*Server) SetCurrentItem

func (s *Server) SetCurrentItem(ctx context.Context, req *gatewaypb.SetCurrentItemRequest) (*gatewaypb.SetCurrentItemResponse, error)

func (*Server) Start

func (s *Server) Start() error