server

Documentation

Index

• Constants
• Variables
• func NewAuthorizationOption(userRole *uservice.UserRoleContrib) *authz.Option
• func NewEventServer(c *kitconf.Data, conn dal.ConnName, logger klog.Logger, uowMgr uow2.Manager, ...) *event.ConsumerFactoryServer
• func NewGRPCServer(c *conf.Services, tokenizer jwt.Tokenizer, ts saas.TenantStore, ...) *kitgrpc.Server
• func NewHTTPServer(c *conf.Services, sCfg *conf.Security, tokenizer jwt.Tokenizer, ...) *kithttp.Server
• func NewJobServer(opt asynq.RedisConnOpt, log klog.Logger, handlers []*job.Handler) *job.Server
• func NewSeeder(ts saas.TenantStore, seeds []seed.Contrib) seed.Seeder

Constants

const ConnName = dal.ConnName("default")

Variables

var ProviderSet = kitdi.NewSet(
	kitdi.NewProvider(NewHTTPServer, di.As(new(transport.Server))),
	kitdi.NewProvider(NewGRPCServer, di.As(new(transport.Server))),
	kitdi.NewProvider(NewJobServer, di.As(new(transport.Server))),
	kitdi.NewProvider(NewEventServer, di.As(new(transport.Server))),
	kitdi.NewProvider(rserver.NewCentrifuge, di.As(new(transport.Server))),
	NewSeeder,
	kitdi.Value(ConnName),
	NewAuthorizationOption,
	userver.NewSeeding,
	sserver.NewSeeding,
	sysserver.NewSeeding,
)

ProviderSet is server providers.

Functions

func NewAuthorizationOption

func NewAuthorizationOption(userRole *uservice.UserRoleContrib) *authz.Option

func NewEventServer

func NewEventServer(
	c *kitconf.Data,
	conn dal.ConnName,
	logger klog.Logger,
	uowMgr uow2.Manager,
	handlers []event.ConsumerHandler,
	container *di.Container,
) *event.ConsumerFactoryServer

func NewGRPCServer

func NewGRPCServer(
	c *conf.Services,
	tokenizer jwt.Tokenizer,
	ts saas.TenantStore,
	uowMgr uow2.Manager,
	mOpt *shttp.WebMultiTenancyOption,
	apiOpt *sapi.Option,
	logger log.Logger,
	validator sapi.TrustedContextValidator,
	userTenant *uapi.UserTenantContrib,
	register []kitgrpc.ServiceRegister,
) *kitgrpc.Server

NewGRPCServer new a gRPC server.

func NewHTTPServer

func NewHTTPServer(c *conf.Services,
	sCfg *conf.Security,
	tokenizer jwt.Tokenizer,
	uowMgr uow2.Manager,
	mOpt *shttp.WebMultiTenancyOption,
	apiOpt *sapi.Option,
	ts saas.TenantStore,
	reqDecoder khttp.DecodeRequestFunc,
	resEncoder khttp.EncodeResponseFunc,
	errEncoder khttp.EncodeErrorFunc,
	logger log.Logger,
	userTenant *uapi.UserTenantContrib,
	validator sapi.TrustedContextValidator,
	refreshProvider session.RefreshTokenProvider,
	register []kithttp.ServiceRegister,
) *kithttp.Server

NewHTTPServer new a HTTP server.

func NewJobServer

func NewJobServer(
	opt asynq.RedisConnOpt,
	log klog.Logger,
	handlers []*job.Handler,
) *job.Server

func NewSeeder

func NewSeeder(ts saas.TenantStore, seeds []seed.Contrib) seed.Seeder