facade

Documentation

Index

• type Service
  • func New(logger *zap.Logger, grpcAddr string, srvDomain *domain.Service) (*Service, error)
  • func (s *Service) Run(ctx context.Context) error
  • func (s *Service) SubscribeOnLeader(req *service.SubscribeOnLeaderRequest, ...) error
  • func (s *Service) Wait()

Types

type Service

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

func New

func New(logger *zap.Logger, grpcAddr string, srvDomain *domain.Service) (*Service, error)

func (*Service) Run

func (s *Service) Run(ctx context.Context) error

func (*Service) SubscribeOnLeader

func (s *Service) SubscribeOnLeader(req *service.SubscribeOnLeaderRequest, srv service.LeaderElectionService_SubscribeOnLeaderServer) error

func (*Service) Wait

func (s *Service) Wait()