private

Documentation

Index

• Variables
• type Service
  • func NewService(l *zap.Logger, db *db.Database, deployment string, appId string) (result *Service, err error)
  • func (s *Service) AddBlocked(_ context.Context, request *pb.AddBlockedRequest) (*pb.AddBlockedResponse, error)
  • func (s *Service) RegisterWithGrpcServer(server siface.IGrpcServer) error

Variables

var ChatService = fx.Provide(
	func(
		l *zap.Logger,
		setting cfx.ChatSettingParams,
		aParams mfx2.AppParams,
		redisParams ofx.RedisParams,
	) (out sfx.GrpcServiceResult, err error) {
		if s, err := NewService(
			l,
			db.OpenDatabase(l, redisParams.Redis),
			aParams.Deployment,
			aParams.AppId,
		); err != nil {
			return out, err
		} else {
			out.GrpcService = s
		}
		return
	},
)

Types

type Service

type Service struct {
	utility.WithoutAuth
	// contains filtered or unexported fields
}

func NewService

func NewService(
	l *zap.Logger,
	db *db.Database,
	deployment string,
	appId string,
) (result *Service, err error)

func (*Service) AddBlocked

func (s *Service) AddBlocked(_ context.Context, request *pb.AddBlockedRequest) (*pb.AddBlockedResponse, error)

func (*Service) RegisterWithGrpcServer

func (s *Service) RegisterWithGrpcServer(server siface.IGrpcServer) error