Documentation ¶
Overview ¶
Code generated by MockGen. DO NOT EDIT. Source: interfaces.go
Generated by this command:
mockgen -source=interfaces.go -destination=interfaces_mock.go -package=usecases
Package usecases is a generated GoMock package.
Index ¶
- Constants
- Variables
- func GenerateMemberName(group string, memberID string) string
- func IsToBeRebalanced(members []*Member) bool
- type Cache
- type Member
- type MemberGroup
- type MemberRepository
- type MemberUseCase
- type MemberUserCase
- func (m MemberUserCase) AddNewMemberToGroup(ctx context.Context, group string) (Member, error)
- func (m MemberUserCase) ClearOrdinals(ctx context.Context, unStableMembers []*Member) error
- func (m MemberUserCase) GetHealthCheckFromMember(ctx context.Context, member Member) (Partition, error)
- func (m MemberUserCase) RemoveMember(ctx context.Context, member Member) error
- func (m MemberUserCase) StopBalance()
- func (m MemberUserCase) TriggerBalance()
- type MockCache
- type MockCacheMockRecorder
- type MockMemberRepository
- type MockMemberRepositoryMockRecorder
- type MockMemberUseCase
- type MockMemberUseCaseMockRecorder
- type Partition
Constants ¶
const IDPrefix = "clerk"
Variables ¶
var ( ErrGroupNotFound = errors.New("group does not exit") ErrMemberNotFound = errors.New("member does not exit") )
var DefaultPartition = Partition{
Ordinal: 0,
Total: 0,
}
Functions ¶
func GenerateMemberName ¶
func IsToBeRebalanced ¶
Types ¶
type Member ¶
type Member struct { Group string `json:"group"` ID string `json:"id"` LastUpdatedTime *time.Time `json:"lastUpdatedTime"` CreatedAt time.Time `json:"createdAt"` Partition }
func (Member) LastActiveDate ¶
type MemberGroup ¶
type MemberGroup struct {
// contains filtered or unexported fields
}
func ConvertToMembersToGroups ¶
func ConvertToMembersToGroups(members []*Member) []*MemberGroup
func NewMemberGroup ¶
func NewMemberGroup() *MemberGroup
func (*MemberGroup) Add ¶
func (m *MemberGroup) Add(member *Member)
func (*MemberGroup) Group ¶
func (m *MemberGroup) Group() string
func (*MemberGroup) IsThereAnyMemberJoinedInTheLast ¶
func (m *MemberGroup) IsThereAnyMemberJoinedInTheLast(d time.Duration) bool
func (*MemberGroup) StableAndUnstableMembers ¶
func (m *MemberGroup) StableAndUnstableMembers(d time.Duration) ([]*Member, []*Member)
type MemberRepository ¶
type MemberRepository interface { SaveNewMember(ctx context.Context, member Member) error DeleteMemberByID(ctx context.Context, id string) error SaveLastUpdatedTimeByID(ctx context.Context, id string, updateTime time.Time) error GetPartitionOfTheMemberByID(ctx context.Context, id string) (Partition, error) FetchAllMembers(ctx context.Context) ([]*Member, error) UpdatePartitions(ctx context.Context, idPartitionMap map[string]Partition) error }
type MemberUseCase ¶
type MemberUserCase ¶
type MemberUserCase struct {
// contains filtered or unexported fields
}
func NewMemberUserCase ¶
func NewMemberUserCase(r MemberRepository, c config.Config) *MemberUserCase
func (MemberUserCase) AddNewMemberToGroup ¶
func (MemberUserCase) ClearOrdinals ¶
func (m MemberUserCase) ClearOrdinals(ctx context.Context, unStableMembers []*Member) error
func (MemberUserCase) GetHealthCheckFromMember ¶
func (MemberUserCase) RemoveMember ¶
func (m MemberUserCase) RemoveMember(ctx context.Context, member Member) error
func (MemberUserCase) StopBalance ¶
func (m MemberUserCase) StopBalance()
func (MemberUserCase) TriggerBalance ¶
func (m MemberUserCase) TriggerBalance()
type MockCache ¶
type MockCache struct {
// contains filtered or unexported fields
}
MockCache is a mock of Cache interface.
func NewMockCache ¶
func NewMockCache(ctrl *gomock.Controller) *MockCache
NewMockCache creates a new mock instance.
func (*MockCache) AddNewInstance ¶
AddNewInstance mocks base method.
func (*MockCache) EXPECT ¶
func (m *MockCache) EXPECT() *MockCacheMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockCacheMockRecorder ¶
type MockCacheMockRecorder struct {
// contains filtered or unexported fields
}
MockCacheMockRecorder is the mock recorder for MockCache.
func (*MockCacheMockRecorder) AddNewInstance ¶
func (mr *MockCacheMockRecorder) AddNewInstance() *gomock.Call
AddNewInstance indicates an expected call of AddNewInstance.
type MockMemberRepository ¶
type MockMemberRepository struct {
// contains filtered or unexported fields
}
MockMemberRepository is a mock of MemberRepository interface.
func NewMockMemberRepository ¶
func NewMockMemberRepository(ctrl *gomock.Controller) *MockMemberRepository
NewMockMemberRepository creates a new mock instance.
func (*MockMemberRepository) EXPECT ¶
func (m *MockMemberRepository) EXPECT() *MockMemberRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMemberRepository) SaveNewMemberToGroup ¶
func (m *MockMemberRepository) SaveNewMemberToGroup(ctx context.Context, group string) (string, error)
SaveNewMemberToGroup mocks base method.
type MockMemberRepositoryMockRecorder ¶
type MockMemberRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockMemberRepositoryMockRecorder is the mock recorder for MockMemberRepository.
func (*MockMemberRepositoryMockRecorder) SaveNewMemberToGroup ¶
func (mr *MockMemberRepositoryMockRecorder) SaveNewMemberToGroup(ctx, group any) *gomock.Call
SaveNewMemberToGroup indicates an expected call of SaveNewMemberToGroup.
type MockMemberUseCase ¶
type MockMemberUseCase struct {
// contains filtered or unexported fields
}
MockMemberUseCase is a mock of MemberUseCase interface.
func NewMockMemberUseCase ¶
func NewMockMemberUseCase(ctrl *gomock.Controller) *MockMemberUseCase
NewMockMemberUseCase creates a new mock instance.
func (*MockMemberUseCase) AddNewMemberToGroup ¶
AddNewMemberToGroup mocks base method.
func (*MockMemberUseCase) EXPECT ¶
func (m *MockMemberUseCase) EXPECT() *MockMemberUseCaseMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockMemberUseCaseMockRecorder ¶
type MockMemberUseCaseMockRecorder struct {
// contains filtered or unexported fields
}
MockMemberUseCaseMockRecorder is the mock recorder for MockMemberUseCase.
func (*MockMemberUseCaseMockRecorder) AddNewMemberToGroup ¶
func (mr *MockMemberUseCaseMockRecorder) AddNewMemberToGroup(ctx, group any) *gomock.Call
AddNewMemberToGroup indicates an expected call of AddNewMemberToGroup.