data

package
v2.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 26, 2021 License: Apache-2.0 Imports: 18 Imported by: 0

README

Generating proto files

Installation

Follow instructions here to install necessary binaries.

Compile

Run make build-proto to compile proto.

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_cron_data_request_proto protoreflect.FileDescriptor

Functions

func BlobExists

func BlobExists(ctx context.Context, bucketURL, key string) (bool, error)

func GetBlobContent

func GetBlobContent(ctx context.Context, bucketURL, key string) ([]byte, error)

func GetBlobFilename

func GetBlobFilename(filename string, datetime time.Time) string

func GetBlobKeys

func GetBlobKeys(ctx context.Context, bucketURL string) ([]string, error)

func GetShardNumFilename

func GetShardNumFilename(datetime time.Time) string

func GetTransferStatusFilename

func GetTransferStatusFilename(datetime time.Time) string

func ParseBlobFilename

func ParseBlobFilename(key string) (time.Time, string, error)

func SortAndAppendFrom

func SortAndAppendFrom(in io.Reader, out io.Writer, newRepos []repos.RepoURL) error

func SortAndAppendTo

func SortAndAppendTo(out io.Writer, oldRepos, newRepos []repos.RepoURL) error

func WriteToBlobStore

func WriteToBlobStore(ctx context.Context, bucketURL, filename string, data []byte) error

Types

type Iterator

type Iterator interface {
	HasNext() bool
	Next() (repos.RepoURL, error)
}

func MakeIteratorFrom

func MakeIteratorFrom(reader io.Reader) (Iterator, error)

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL