protocol

type BinaryObjectType byte

type CASCacheman interface {
	FetchGitObjectRequest(key entities.Hash) (cacheman.ResultType, error)
	FetchObjectRequest(key entities.Hash, objType cacheman.RequestObjectType) (cacheman.ResultType, error)
	FetchStatRequest(key entities.Hash) (entities.StatInfo, error)
	SendNewObject(key entities.Hash, objType cacheman.RequestObjectType) error
	SendNotifyUse(key entities.Hash) error

	Close() error
}

type CacheManStats struct {
	Connected    bool
	TotalSize    int64
	LRUSize      int64
	LocalCount   int64
	IndexCount   int64
	GCStart      time.Time
	GCEnd        time.Time
	EvictStart   time.Time
	EvictEnd     time.Time
	EvictCount   int64
	OldestObject time.Time
	ClientStat
	FetchBlobs    *QueueStat
	FetchTrees    *QueueStat
	FetchObjects  *QueueStat
	FetchARIs     *QueueStat
	FetchCASBlobs *QueueStat
	FetchMaps     *QueueStat
	OverallPushStat
	PushBlobs   PushGroupStat
	PushObjects PushGroupStat
	PushTrees   PushGroupStat
	PushRefs    PushGroupStat
	PushMaps    PushGroupStat
	Phony       PushGroupStat
	Execute     ExecStat
	Fallback    FallbackStats
}

type CheckStatusReq struct {
	RequestID RequestID
}

type CheckStatusResp struct {
	RequestID RequestID
	Result    ResultType
	ErrorCode int32
}

type CleanReq struct {
	Blobs   bool
	Objects bool
	Hashes  []string
}

type ClientStat struct {
	BytesSent     int64
	LastSent      time.Time
	BytesReceived int64
	LastReceived  time.Time
}

type ExecStat struct {
	Request int64
	Success int64
	Failed  int64
}

type ExecuteRequest struct {
	EvalRequest    entities.Hash
	Patches        []entities.Hash
	StoreMapResult bool
	PrefetchInputs bool
}

type ExecutionStat struct {
	Request atomic.Int64
	Success atomic.Int64
	Failed  atomic.Int64
}

type FallbackStats struct {
	Methods map[string]int64 `json:"methods"`
	Types   map[string]int64 `json:"types"`
}

type FetchARIReq struct {
	RequestID RequestID
	ARI       string
}

type FetchCASBlobReq struct {
	RequestID RequestID
	SHA256    entities.SHA256
	Size      int64
}

type FetchObjectReq struct {
	RequestID RequestID
	Hash      entities.Hash
}

type FetchObjectResp struct {
	RequestID RequestID
	Result    ResultType
}

type FetchStatReq struct {
	RequestID RequestID
	Hash      entities.Hash
}

type FetchStatResp struct {
	RequestID  RequestID
	Result     ResultType
	Size       int64
	Mode       uint32
	ObjectType BinaryObjectType
}

type GetRefsReq struct {
	Server  string
	Project string
	Refs    []string
}

type HTTP interface {
	GetRefs(server string, project string, refs []string) ([]entities.Hash, error)
	PutRefs(server string, project string, refs []entities.RefHash, blocking bool) error
	SearchRefs(server string, project string, refPrefix string, limit int) ([]entities.ProjectRefHash, error)
	UseMany(hashes []entities.Hash) error
	WaitIdle(timeout time.Duration) error
	Clean(req CleanReq) error
	SendNewMap(from, to entities.Hash, localOnly bool) error
	FetchMapRequest(key entities.Hash) error
	MapResults(from entities.Hash) ([]entities.Hash, error)
	Execute(req entities.Hash, patches []entities.Hash, storeMapResult, PrefetchInputs bool) (resp entities.Hash, err error)
	WaitFor(timeout time.Duration, priority float64, objects []entities.Hash) (err error)
	Stats() (CacheManStats, error)
	KeepAlive(key entities.Hash) error
	IsObjectRemote(key entities.Hash) (bool, error)
	StartGC() error
	Prefetch(blobs, objects []entities.Hash, priority float64) error
	PushBuildMetrics(req *PushBuildMetricsReq) error
}

type IdentityGetReq struct {
	SHA1 entities.Hash
}

type IdentityGetResp struct {
	Found  bool
	SHA256 string
	Size   int64
	Type   int // 0: File, 1: Symlink, 2: Directory
}

type IdentityPutReq struct {
	SHA1   entities.Hash
	SHA256 string
	Size   int64
	Type   int // 0: File, 1: Symlink, 2: Directory
}

type MessageType byte

type NewMapMessage struct {
	From      entities.Hash
	To        entities.Hash
	LocalOnly bool
}

type NewObjectMessage struct {
	Hash entities.Hash
}

type OverallPushStat struct {
	BrokenLinks    int64
	MissingObjects int64
}

type PrefetchRequest struct {
	Blobs    []entities.Hash
	Objects  []entities.Hash
	Priority float64
}

type ProjectRefHash struct {
	Project string
	Ref     string
	Hash    string
}

type PushBuildMetricsReq struct {
	AndroidTarget     string
	BuildGoal         string
	Status            string
	BuildDurationSecs float64
	HasNinjaRun       bool
	CacheHitRatio     float64
	CacheHitCount     uint32
	CacheMissCount    uint32
	Phases            map[string]float64
}

type PushGroupStat struct {
	Requests int64
	Queued   int64
	Blocked  int64
	Pushing  int64
	Failed   int64
}

type PushStat struct {
	Request atomic.Int64
	Report  atomic.Int64
}

type PutRefsReq struct {
	Server   string
	Project  string
	Refs     []RefHash
	Blocking bool
}

type QueueStat struct {
	Input   atomic.Int64
	Output  atomic.Int64
	Active  atomic.Int64
	Retries atomic.Int64
	Errors  atomic.Int64
}

type RefHash struct {
	Ref  string
	Hash string
}

type RequestID uint32

type RequestObjectType byte

type ResultType byte

type SearchRefsReq struct {
	Server    string
	Project   string
	RefPrefix string
	Limit     int
}

type UdsIdentityGetReq struct {
	RequestID RequestID
	SHA1      entities.Hash
}

type UdsIdentityGetResp struct {
	RequestID RequestID
	Result    ResultType
	SHA256    [32]byte
	Size      int64
	Type      byte
}

type UdsIdentityPutReq struct {
	RequestID RequestID
	SHA1      entities.Hash
	SHA256    [32]byte
	Size      int64
	Type      byte
}

type UdsInitDeeptreeReq struct {
	RequestID RequestID
	SHA1      entities.Hash
}

type UdsInitDeeptreeResp struct {
	RequestID RequestID
	Result    ResultType
	SHA1      entities.Hash
}

type UdsMapResultsReq struct {
	RequestID RequestID
	SHA1      entities.Hash
}

type UdsPutInMapReq struct {
	RequestID RequestID
	From      entities.Hash
	To        entities.Hash
	LocalOnly byte
}

type WaitForRequest struct {
	TimeoutSecs float64 // Zero means no timeout.
	Priority    float64
	Objects     []entities.Hash
}