Documentation
¶
Index ¶
- Variables
- func BlobExists(ctx context.Context, bucketURL, key string) (bool, error)
- func GetBlobContent(ctx context.Context, bucketURL, key string) ([]byte, error)
- func GetBlobFilename(filename string, datetime time.Time) string
- func GetBlobKeys(ctx context.Context, bucketURL string) ([]string, error)
- func GetShardNumFilename(datetime time.Time) string
- func GetTransferStatusFilename(datetime time.Time) string
- func ParseBlobFilename(key string) (time.Time, string, error)
- func SortAndAppendFrom(in io.Reader, out io.Writer, newRepos []repos.RepoURL) error
- func SortAndAppendTo(out io.Writer, oldRepos, newRepos []repos.RepoURL) error
- func WriteToBlobStore(ctx context.Context, bucketURL, filename string, data []byte) error
- type Iterator
- type ScorecardBatchRequest
- func (*ScorecardBatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ScorecardBatchRequest) GetJobTime() *timestamppb.Timestamp
- func (x *ScorecardBatchRequest) GetRepos() []string
- func (x *ScorecardBatchRequest) GetShardNum() int32
- func (*ScorecardBatchRequest) ProtoMessage()
- func (x *ScorecardBatchRequest) ProtoReflect() protoreflect.Message
- func (x *ScorecardBatchRequest) Reset()
- func (x *ScorecardBatchRequest) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_cron_data_request_proto protoreflect.FileDescriptor
Functions ¶
func GetBlobContent ¶
func GetShardNumFilename ¶
func SortAndAppendFrom ¶
func SortAndAppendTo ¶
Types ¶
type ScorecardBatchRequest ¶
type ScorecardBatchRequest struct {
Repos []string `protobuf:"bytes,1,rep,name=repos,proto3" json:"repos,omitempty"`
ShardNum *int32 `protobuf:"varint,2,opt,name=shard_num,json=shardNum,proto3,oneof" json:"shard_num,omitempty"`
JobTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=job_time,json=jobTime,proto3,oneof" json:"job_time,omitempty"`
// contains filtered or unexported fields
}
func (*ScorecardBatchRequest) Descriptor
deprecated
func (*ScorecardBatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use ScorecardBatchRequest.ProtoReflect.Descriptor instead.
func (*ScorecardBatchRequest) GetJobTime ¶
func (x *ScorecardBatchRequest) GetJobTime() *timestamppb.Timestamp
func (*ScorecardBatchRequest) GetRepos ¶
func (x *ScorecardBatchRequest) GetRepos() []string
func (*ScorecardBatchRequest) GetShardNum ¶
func (x *ScorecardBatchRequest) GetShardNum() int32
func (*ScorecardBatchRequest) ProtoMessage ¶
func (*ScorecardBatchRequest) ProtoMessage()
func (*ScorecardBatchRequest) ProtoReflect ¶
func (x *ScorecardBatchRequest) ProtoReflect() protoreflect.Message
func (*ScorecardBatchRequest) Reset ¶
func (x *ScorecardBatchRequest) Reset()
func (*ScorecardBatchRequest) String ¶
func (x *ScorecardBatchRequest) String() string
Click to show internal directories.
Click to hide internal directories.