api

type AccessKey string

type Address struct{ *url.URL }

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

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

type Addresser interface {
	Address() *Address
}

type App interface {
	Name() string
	DefineFlags(f *flag.FlagSet)
	Setup() error
}

type DataPartition interface{}

type DataPartitionID interface{}

type DataService interface{}

type Gateway interface {
	ListBuckets() (*ListAllMyBucketsResult, error)
}

type GroupID string

type LeaderChecker interface {
	CheckLeader() error
}

type ListAllMyBucketsResult struct{}

type Member interface {
	AskLeaderID() (*raft.ServerID, error)
}

type MetaKey interface {
	ClientID() string
	Bucket() string
	Key() string
}

type MetaPartition interface {
	Peer

	StartKey() string
	EndKey() string
	KeyCount() int

	Get(key string) (Metadata, error)
	Put(key string, m Metadata) error
}

type MetaService interface {
	Lookup(key MetaKey) (MetaPartition, error)
}

type Metadata interface {
	Size() int
	PartCount() int
	Parts() []DataPartitionID

	ContentType() string
	UserMeta() map[string]string
}

type MuxDefiner interface {
	DefineMux(mux *http.ServeMux)
}

type NodeHost string

type Peer interface {
	Addresser

	ID() raft.ServerID
	Suffrage() raft.ServerSuffrage

	json.Marshaler
	json.Unmarshaler
}

type Peers interface {
	Peers() []Peer
	Configuration() raft.Configuration
	Lookup(id raft.ServerID) (Peer, error)
}

type Placer interface {
	Member

	ListGroups() (*[]GroupID, error)
	GenerateGroup() (*GroupID, error)
}

type RpcID string

type SecretKey string

type Server interface {
	App

	io.Closer
	Host() string
}

type SigChecker interface {
	CheckSigV4(r *http.Request) (bool, error)
	WithSigV4(f http.HandlerFunc) http.HandlerFunc
}

type StreamLayerMux interface {
	io.Closer
	NetworkLayer(groupID GroupID) raft.StreamLayer
}

type Tenant struct {
	DisplayName string
	AccessKey   AccessKey
	SecretKey   SecretKey
}

type Tenants interface {
	Get(ak AccessKey) (*Tenant, error)
	ListAll() ([]AccessKey, error)
}