api

Documentation

Index

• type Option
  • func WithLogger(l *zap.Logger) Option
• type PushService
  • func NewPushService(mysqlClient mysql.Client, featureClient featureclient.Client, ...) *PushService
  • func (s *PushService) CreatePush(ctx context.Context, req *pushproto.CreatePushRequest) (*pushproto.CreatePushResponse, error)
  • func (s *PushService) DeletePush(ctx context.Context, req *pushproto.DeletePushRequest) (*pushproto.DeletePushResponse, error)
  • func (s *PushService) ListPushes(ctx context.Context, req *pushproto.ListPushesRequest) (*pushproto.ListPushesResponse, error)
  • func (s *PushService) Register(server *grpc.Server)
  • func (s *PushService) UpdatePush(ctx context.Context, req *pushproto.UpdatePushRequest) (*pushproto.UpdatePushResponse, error)

Types

type Option

type Option func(*options)

func WithLogger

func WithLogger(l *zap.Logger) Option

type PushService

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

func NewPushService

func NewPushService(
	mysqlClient mysql.Client,
	featureClient featureclient.Client,
	experimentClient experimentclient.Client,
	accountClient accountclient.Client,
	publisher publisher.Publisher,
	opts ...Option,
) *PushService

func (*PushService) CreatePush

func (s *PushService) CreatePush(
	ctx context.Context,
	req *pushproto.CreatePushRequest,
) (*pushproto.CreatePushResponse, error)

func (*PushService) DeletePush

func (s *PushService) DeletePush(
	ctx context.Context,
	req *pushproto.DeletePushRequest,
) (*pushproto.DeletePushResponse, error)

func (*PushService) ListPushes

func (s *PushService) ListPushes(
	ctx context.Context,
	req *pushproto.ListPushesRequest,
) (*pushproto.ListPushesResponse, error)

func (*PushService) Register

func (s *PushService) Register(server *grpc.Server)

func (*PushService) UpdatePush

func (s *PushService) UpdatePush(
	ctx context.Context,
	req *pushproto.UpdatePushRequest,
) (*pushproto.UpdatePushResponse, error)