raftstorage

Documentation

Index

• type ReplicaStorage
  • func NewReplicaStorage(myAddress string, serviceName string, redisClient *redis.Client) *ReplicaStorage
  • func (rs *ReplicaStorage) GetMyAddress() string
  • func (rs *ReplicaStorage) GetReplicas() (replicas []string, err error)
• type Storage
  • func NewDummyStorage(myAddress string, allAddresses ...string) Storage

Types

type ReplicaStorage

type ReplicaStorage struct {
	app.Runner
	// contains filtered or unexported fields
}

func NewReplicaStorage

func NewReplicaStorage(myAddress string, serviceName string, redisClient *redis.Client) *ReplicaStorage

func (*ReplicaStorage) GetMyAddress

func (rs *ReplicaStorage) GetMyAddress() string

func (*ReplicaStorage) GetReplicas

func (rs *ReplicaStorage) GetReplicas() (replicas []string, err error)

type Storage

type Storage interface {
	GetMyAddress() string
	GetReplicas() ([]string, error)
	app.Runner
}

func NewDummyStorage

func NewDummyStorage(myAddress string, allAddresses ...string) Storage