async

type ClusterDelegate struct {
	Meta ClusterDelegateMetaData
}

type ClusterDelegateMetaData struct {
	ServerType    string
	ServerAddress string
}

type ClusterEventDelegate struct {
	Logger        log.Logger
	Shard         int
	ServerAddress string
	AsyncService  *Service
	// contains filtered or unexported fields
}

type Membership interface {
	GetServerAddress() string
	GetAsyncServerAddressForShard(shardId int32) string
}

type Server interface {
	// Start will start running on the background
	Start() error
	Stop(ctx context.Context) error
}

type Service interface {
	Start() error
	NotifyPollingImmediateTask(req xcapi.NotifyImmediateTasksRequest) error
	NotifyPollingTimerTask(req xcapi.NotifyTimerTasksRequest) error
	NotifyRemoteImmediateTaskAsyncInCluster(req xcapi.NotifyImmediateTasksRequest, serverAddress string)
	NotifyRemoteTimerTaskAsyncInCluster(req xcapi.NotifyTimerTasksRequest, serverAddress string)
	Stop(ctx context.Context) error
	ReBalance(assignedShardIds []int32)
}