sharder

type AWSTaskMetadata struct {
	TaskARN string
}

type Controller struct {
	Distributor ShardDistributor
	ShardConfig
	StorageConfig map[string]interface{}
	sync.RWMutex
}

type ControllerConfig struct {
	//Name string
	ShardConfig
	StorageConfig StorageConfig
	NodeName      string
}

type NodeStateManager interface {
	GetActiveNodes() ([]string, error)
	RemoveNode()
	Stop()
}

type ShardConfig struct {
	Identity    string   `json:"identity"`
	NumShards   int      `json:"clusterShardNumber"`
	OwnedShards []string `json:"ownedShards"`
}

type ShardDistributor interface {
	// Stop shuts down any resources used
	Stop()
	// Updates
	//return the ShardConfig channel
	Updates() ShardUpdater
	// Peers returns the list of healthy nodes
	Nodes() []string
	// Identity returns the identity of this node
	Identity() string
	// UpdateNumberShards sets a new number of shards, rehashes shards and publishes updates
	UpdateNumberShards(numShards int)
}

type ShardStatus struct {
	Shard      string `json:"shard"`
	LastPolled string `json:"lastPolledAt"`
}

type ShardUpdater chan ShardConfig

type SimpleHashDistributor struct {
	ShardConfig

	sync.Mutex
	// contains filtered or unexported fields
}

type StorageConfig struct {
	StorageType            string
	StorageRegion          string
	StorageTable           string
	StorageTag             string
	UpdateFrequencySeconds int
	UpdateTtlSeconds       int
	ForcedHostname         string
}