client

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

type ControllContractor interface {
	LatestData(ctx context.Context, ldr rStructs.LatestDataRequest) (ldResp rStructs.LatestDataResponse, err error)
	SyncData(ctx context.Context, ldr rStructs.SyncDataRequest) (ldResp rStructs.SyncDataResponse, err error)
	RewardsData(ctx context.Context, ldr rStructs.RewardsDataRequest) (ldResp rStructs.RewardsDataResponse, err error)
	LatestRewardsData(ctx context.Context, ldr rStructs.RewardsDataRequest) (ldResp rStructs.RewardsDataResponse, err error)
}

type NetworkVersion struct {
	Network string
	ChainID string
	Version string
}

type PSig struct {
	TaskID  string
	Network string
	ChainID string
	Version string
}

type ProcessLatestData struct {
	Started   time.Time
	Finished  bool
	EndHeight uint64
	Error     error
	Resp      shared.LatestDataResponse
	Retries   uint64
}

type ProcessLatestRewardsData struct {
	Started   time.Time
	Finished  bool
	EndHeight uint64
	Error     error
	Resp      shared.RewardsDataResponse
	Retries   uint64
}

type ProcessRewardsData struct {
	Started   time.Time
	Finished  bool
	EndHeight uint64
	LastTime  time.Time
	Error     error
	Resp      shared.RewardsDataResponse
	Retries   uint64
}

type ProcessSyncData struct {
	Started   time.Time
	Finished  bool
	EndHeight uint64
	Error     error
	Resp      shared.SyncDataResponse
	Retries   uint64
}

type Running struct {
	ProcessesSyncData          map[PSig]ProcessSyncData
	ProcessesLatestData        map[PSig]ProcessLatestData
	ProcessesRewardsData       map[PSig]ProcessRewardsData
	ProcessesLatestRewardsData map[PSig]ProcessLatestRewardsData
	// contains filtered or unexported fields
}

type TaskSender interface {
	Send([]cStructs.TaskRequest) (*cStructs.Await, error)
}