Documentation ¶
Index ¶
- func CreateETCDClient(cfg config.Config) (*clientv3.Client, error)
- func Stop(client *clientv3.Client) error
- type MemberETCDRepository
- func (m *MemberETCDRepository) DeleteMemberByID(ctx context.Context, id string) error
- func (m *MemberETCDRepository) FetchAllMembers(ctx context.Context) ([]*usecases.Member, error)
- func (m *MemberETCDRepository) FetchMemberByID(ctx context.Context, id string) (*usecases.Member, error)
- func (m *MemberETCDRepository) GetPartitionOfTheMemberByID(ctx context.Context, id string) (usecases.Partition, error)
- func (m *MemberETCDRepository) SaveLastUpdatedTimeByID(ctx context.Context, id string, updateTime time.Time) error
- func (m *MemberETCDRepository) SaveNewMember(ctx context.Context, member usecases.Member) error
- func (m *MemberETCDRepository) UpdatePartitions(ctx context.Context, idPartitionMap map[string]usecases.Partition) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateETCDClient ¶
Types ¶
type MemberETCDRepository ¶
type MemberETCDRepository struct {
// contains filtered or unexported fields
}
func NewMemberETCDRepository ¶
func NewMemberETCDRepository(e *clientv3.Client) *MemberETCDRepository
func (*MemberETCDRepository) DeleteMemberByID ¶
func (m *MemberETCDRepository) DeleteMemberByID(ctx context.Context, id string) error
func (*MemberETCDRepository) FetchAllMembers ¶
func (*MemberETCDRepository) FetchMemberByID ¶
func (*MemberETCDRepository) GetPartitionOfTheMemberByID ¶
func (*MemberETCDRepository) SaveLastUpdatedTimeByID ¶
func (*MemberETCDRepository) SaveNewMember ¶
func (*MemberETCDRepository) UpdatePartitions ¶
Click to show internal directories.
Click to hide internal directories.