usecases

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 26, 2024 License: MIT Imports: 10 Imported by: 0

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

View Source 
const IDPrefix = "clerk"

Variables

View Source 
var (
	ErrGroupNotFound  = errors.New("group does not exit")
	ErrMemberNotFound = errors.New("member does not exit")
)
View Source 
var DefaultPartition = Partition{
	Ordinal: 0,
	Total:   0,
}

Functions

func GenerateMemberName 

func GenerateMemberName(group string, memberID string) string

func IsToBeRebalanced 

func IsToBeRebalanced(members []*Member) bool

Types

type Cache 

type Cache interface {
	AddNewInstance() (int, error)
}

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) IsActiveForTheLast 

func (m Member) IsActiveForTheLast(duration time.Duration) bool

func (Member) LastActiveDate 

func (m Member) LastActiveDate() time.Time

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 MemberUseCase interface {
	AddNewMemberToGroup(ctx context.Context, group string) (Member, error)
	GetHealthCheckFromMember(ctx context.Context, member Member) (Partition, error)
	RemoveMember(ctx context.Context, member Member) error
	TriggerBalance()
	StopBalance()
}

type MemberUserCase 

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

func NewMemberUserCase 

func NewMemberUserCase(r MemberRepository, c config.Config) *MemberUserCase

func (MemberUserCase) AddNewMemberToGroup 

func (m MemberUserCase) AddNewMemberToGroup(ctx context.Context, group string) (Member, error)

func (MemberUserCase) ClearOrdinals 

func (m MemberUserCase) ClearOrdinals(ctx context.Context, unStableMembers []*Member) error

func (MemberUserCase) GetHealthCheckFromMember 

func (m MemberUserCase) GetHealthCheckFromMember(ctx context.Context, member Member) (Partition, error)

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 

func (m *MockCache) AddNewInstance() (int, error)

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 

func (m *MockMemberUseCase) AddNewMemberToGroup(ctx context.Context, group string) (Member, error)

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.

type Partition 

type Partition struct {
	Ordinal int `json:"ordinal"`
	Total   int `json:"total"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.