counter

Documentation

Index

• type Client
• type ClientImpl
  • func NewClientImpl(logger *zap.Logger, conn *grpc.ClientConn) *ClientImpl
  • func (c *ClientImpl) CreateDialogCounters(ctx context.Context, dialogID model.DialogID, ...) error
  • func (c *ClientImpl) FlushDialogCountersForUser(ctx context.Context, dialogID model.DialogID, userID model.UserID) error
  • func (c *ClientImpl) IncreaseDialogCounters(ctx context.Context, dialogID model.DialogID, senderID model.UserID, ...) error
• type ClientMock
  • func NewClientMock(logger *zap.Logger) *ClientMock
  • func (m *ClientMock) CreateDialogCounters(ctx context.Context, dialogID model.DialogID, ...) error
  • func (m *ClientMock) FlushDialogCountersForUser(ctx context.Context, dialogID model.DialogID, userID model.UserID) error
  • func (m *ClientMock) IncreaseDialogCounters(ctx context.Context, dialogID model.DialogID, senderID model.UserID, ...) error

Types

type Client

type Client interface {
	CreateDialogCounters(ctx context.Context, dialogID model.DialogID, participants []*model.Participant) error
	IncreaseDialogCounters(ctx context.Context, dialogID model.DialogID, senderID model.UserID, participants []*model.Participant) error
	FlushDialogCountersForUser(ctx context.Context, dialogID model.DialogID, userID model.UserID) error
}

type ClientImpl

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

func NewClientImpl

func NewClientImpl(logger *zap.Logger, conn *grpc.ClientConn) *ClientImpl

func (*ClientImpl) CreateDialogCounters

func (c *ClientImpl) CreateDialogCounters(ctx context.Context, dialogID model.DialogID, participants []*model.Participant) error

func (*ClientImpl) FlushDialogCountersForUser

func (c *ClientImpl) FlushDialogCountersForUser(ctx context.Context, dialogID model.DialogID, userID model.UserID) error

func (*ClientImpl) IncreaseDialogCounters

func (c *ClientImpl) IncreaseDialogCounters(ctx context.Context, dialogID model.DialogID, senderID model.UserID, participants []*model.Participant) error

type ClientMock

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

func NewClientMock

func NewClientMock(logger *zap.Logger) *ClientMock

func (*ClientMock) CreateDialogCounters

func (m *ClientMock) CreateDialogCounters(ctx context.Context, dialogID model.DialogID, participants []*model.Participant) error

func (*ClientMock) FlushDialogCountersForUser

func (m *ClientMock) FlushDialogCountersForUser(ctx context.Context, dialogID model.DialogID, userID model.UserID) error

func (*ClientMock) IncreaseDialogCounters

func (m *ClientMock) IncreaseDialogCounters(ctx context.Context, dialogID model.DialogID, senderID model.UserID, participants []*model.Participant) error