raft

type AllocCommand struct {
	Namespace string
	Resource  string
	Tokens    int64
	Version   int64
	SMResult  statemachine.Result
}

type AllocCommandResult struct {
	RemainingTokens int64
	CurrentVersion  int64
	OK              bool
	Err             string
}

type Command interface {
	Type() CommandType
	RaftInvoke(ctx context.Context, nh *dragonboat.NodeHost, shardID uint64, session *client.Session) (result any, err error)
	LocalInvoke(storage *storage, entryIdx uint64) error
	Result() statemachine.Result
}

type CommandType byte

type Config struct {
	BindAddress             string `yaml:"bind_address"`
	BindPort                int    `yaml:"bind_port"`
	BindAddressFromHostname bool   `yaml:"bind_address_from_hostname"`
	DeploymentID            uint64 `yaml:"deployment_id"`
	ReplicaID               uint64 `yaml:"replica_id"`
	ReplicaIDOverride       string `yaml:"replica_id_override"`
	ShardID                 uint64 `yaml:"shard_id"`
	Shards                  uint64 `yaml:"shards"`
	Dir                     string `yaml:"dir"`
}

type FreeCommand struct {
	Namespace string
	Resource  string
	Tokens    int64
	Version   int64
	SMResult  statemachine.Result
}

type FreeCommandResult struct {
	RemainingTokens int64
	CurrentVersion  int64
	OK              bool
	Err             string
}

type RegisterQuotaCommand struct {
	Namespace string
	Resource  string
	Cfg       quota.Config
	SMResult  statemachine.Result
}

type RegisterQuotaCommandResult struct{}

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

type ViewCommand struct {
	Namespace string
	Resource  string
	SMResult  statemachine.Result
}

type ViewCommandResult struct {
	Allocated int64
	Capacity  int64
	Version   int64
	Err       string
}