proxy

package
v0.0.0-...-e006c75 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 12 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ExecutionStrategy_Value_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "LOCAL",
		2: "REMOTE",
		3: "REMOTE_LOCAL_FALLBACK",
		4: "RACING",
	}
	ExecutionStrategy_Value_value = map[string]int32{
		"UNSPECIFIED":           0,
		"LOCAL":                 1,
		"REMOTE":                2,
		"REMOTE_LOCAL_FALLBACK": 3,
		"RACING":                4,
	}
)

Enum value maps for ExecutionStrategy_Value.

View Source 
var (
	LocalExecutionOptions_LocalExecutionPlatform_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "DOCKER",
	}
	LocalExecutionOptions_LocalExecutionPlatform_value = map[string]int32{
		"UNSPECIFIED": 0,
		"DOCKER":      1,
	}
)

Enum value maps for LocalExecutionOptions_LocalExecutionPlatform.

View Source 
var File_api_proxy_depscache_proto protoreflect.FileDescriptor
View Source 
var File_api_proxy_mismatch_ignore_rule_proto protoreflect.FileDescriptor
View Source 
var File_api_proxy_proxy_proto protoreflect.FileDescriptor

Functions

func RegisterCommandsServer 

func RegisterCommandsServer(s *grpc.Server, srv CommandsServer)

func RegisterStatsServer 

func RegisterStatsServer(s *grpc.Server, srv StatsServer)

func RegisterStatusServer 

func RegisterStatusServer(s *grpc.Server, srv StatusServer)

Types

type AddProxyEventsRequest 

type AddProxyEventsRequest struct {
	EventTimes map[string]*command.TimeInterval `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AddProxyEventsRequest) Descriptor deprecated 

func (*AddProxyEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddProxyEventsRequest.ProtoReflect.Descriptor instead.

func (*AddProxyEventsRequest) GetEventTimes 

func (x *AddProxyEventsRequest) GetEventTimes() map[string]*command.TimeInterval

func (*AddProxyEventsRequest) ProtoMessage 

func (*AddProxyEventsRequest) ProtoMessage()

func (*AddProxyEventsRequest) ProtoReflect 

func (x *AddProxyEventsRequest) ProtoReflect() protoreflect.Message

func (*AddProxyEventsRequest) Reset 

func (x *AddProxyEventsRequest) Reset()

func (*AddProxyEventsRequest) String 

func (x *AddProxyEventsRequest) String() string

type AddProxyEventsResponse 

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

func (*AddProxyEventsResponse) Descriptor deprecated 

func (*AddProxyEventsResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddProxyEventsResponse.ProtoReflect.Descriptor instead.

func (*AddProxyEventsResponse) ProtoMessage 

func (*AddProxyEventsResponse) ProtoMessage()

func (*AddProxyEventsResponse) ProtoReflect 

func (x *AddProxyEventsResponse) ProtoReflect() protoreflect.Message

func (*AddProxyEventsResponse) Reset 

func (x *AddProxyEventsResponse) Reset()

func (*AddProxyEventsResponse) String 

func (x *AddProxyEventsResponse) String() string

type CommandsClient 

type CommandsClient interface {
	RunCommand(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
}

CommandsClient is the client API for Commands service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCommandsClient 

func NewCommandsClient(cc grpc.ClientConnInterface) CommandsClient

type CommandsServer 

type CommandsServer interface {
	RunCommand(context.Context, *RunRequest) (*RunResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
}

CommandsServer is the server API for Commands service.

type Deps 

type Deps struct {
	SrcFile       *FileInfo              `protobuf:"bytes,1,opt,name=src_file,json=srcFile,proto3" json:"src_file,omitempty"`
	CommandDigest string                 `protobuf:"bytes,2,opt,name=command_digest,json=commandDigest,proto3" json:"command_digest,omitempty"`
	LastUsed      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_used,json=lastUsed,proto3" json:"last_used,omitempty"`
	DepIds        []int64                `protobuf:"varint,4,rep,packed,name=dep_ids,json=depIds,proto3" json:"dep_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*Deps) Descriptor deprecated 

func (*Deps) Descriptor() ([]byte, []int)

Deprecated: Use Deps.ProtoReflect.Descriptor instead.

func (*Deps) GetCommandDigest 

func (x *Deps) GetCommandDigest() string

func (*Deps) GetDepIds 

func (x *Deps) GetDepIds() []int64

func (*Deps) GetLastUsed 

func (x *Deps) GetLastUsed() *timestamppb.Timestamp

func (*Deps) GetSrcFile 

func (x *Deps) GetSrcFile() *FileInfo

func (*Deps) ProtoMessage 

func (*Deps) ProtoMessage()

func (*Deps) ProtoReflect 

func (x *Deps) ProtoReflect() protoreflect.Message

func (*Deps) Reset 

func (x *Deps) Reset()

func (*Deps) String 

func (x *Deps) String() string

type DepsDatabase 

type DepsDatabase struct {
	Files   []*FileInfo `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	Deps    []*Deps     `protobuf:"bytes,2,rep,name=deps,proto3" json:"deps,omitempty"`
	Version string      `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*DepsDatabase) Descriptor deprecated 

func (*DepsDatabase) Descriptor() ([]byte, []int)

Deprecated: Use DepsDatabase.ProtoReflect.Descriptor instead.

func (*DepsDatabase) GetDeps 

func (x *DepsDatabase) GetDeps() []*Deps

func (*DepsDatabase) GetFiles 

func (x *DepsDatabase) GetFiles() []*FileInfo

func (*DepsDatabase) GetVersion 

func (x *DepsDatabase) GetVersion() string

func (*DepsDatabase) ProtoMessage 

func (*DepsDatabase) ProtoMessage()

func (*DepsDatabase) ProtoReflect 

func (x *DepsDatabase) ProtoReflect() protoreflect.Message

func (*DepsDatabase) Reset 

func (x *DepsDatabase) Reset()

func (*DepsDatabase) String 

func (x *DepsDatabase) String() string

type ExecutionStrategy 

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

func (*ExecutionStrategy) Descriptor deprecated 

func (*ExecutionStrategy) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionStrategy.ProtoReflect.Descriptor instead.

func (*ExecutionStrategy) ProtoMessage 

func (*ExecutionStrategy) ProtoMessage()

func (*ExecutionStrategy) ProtoReflect 

func (x *ExecutionStrategy) ProtoReflect() protoreflect.Message

func (*ExecutionStrategy) Reset 

func (x *ExecutionStrategy) Reset()

func (*ExecutionStrategy) String 

func (x *ExecutionStrategy) String() string

type ExecutionStrategy_Value 

type ExecutionStrategy_Value int32
const (
	ExecutionStrategy_UNSPECIFIED           ExecutionStrategy_Value = 0
	ExecutionStrategy_LOCAL                 ExecutionStrategy_Value = 1
	ExecutionStrategy_REMOTE                ExecutionStrategy_Value = 2
	ExecutionStrategy_REMOTE_LOCAL_FALLBACK ExecutionStrategy_Value = 3
	ExecutionStrategy_RACING                ExecutionStrategy_Value = 4
)

func (ExecutionStrategy_Value) Descriptor 

func (ExecutionStrategy_Value) Descriptor() protoreflect.EnumDescriptor

func (ExecutionStrategy_Value) Enum 

func (x ExecutionStrategy_Value) Enum() *ExecutionStrategy_Value

func (ExecutionStrategy_Value) EnumDescriptor deprecated 

func (ExecutionStrategy_Value) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecutionStrategy_Value.Descriptor instead.

func (ExecutionStrategy_Value) Number 

func (x ExecutionStrategy_Value) Number() protoreflect.EnumNumber

func (ExecutionStrategy_Value) String 

func (x ExecutionStrategy_Value) String() string

func (ExecutionStrategy_Value) Type 

func (ExecutionStrategy_Value) Type() protoreflect.EnumType

type FileInfo 

type FileInfo struct {
	AbsPath string                 `protobuf:"bytes,1,opt,name=abs_path,json=absPath,proto3" json:"abs_path,omitempty"`
	Digest  string                 `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	Mtime   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=mtime,proto3" json:"mtime,omitempty"`
	// contains filtered or unexported fields
}

func (*FileInfo) Descriptor deprecated 

func (*FileInfo) Descriptor() ([]byte, []int)

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetAbsPath 

func (x *FileInfo) GetAbsPath() string

func (*FileInfo) GetDigest 

func (x *FileInfo) GetDigest() string

func (*FileInfo) GetMtime 

func (x *FileInfo) GetMtime() *timestamppb.Timestamp

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect 

func (x *FileInfo) ProtoReflect() protoreflect.Message

func (*FileInfo) Reset 

func (x *FileInfo) Reset()

func (*FileInfo) String 

func (x *FileInfo) String() string

type GetRecordsRequest 

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

func (*GetRecordsRequest) Descriptor deprecated 

func (*GetRecordsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRecordsRequest.ProtoReflect.Descriptor instead.

func (*GetRecordsRequest) ProtoMessage 

func (*GetRecordsRequest) ProtoMessage()

func (*GetRecordsRequest) ProtoReflect 

func (x *GetRecordsRequest) ProtoReflect() protoreflect.Message

func (*GetRecordsRequest) Reset 

func (x *GetRecordsRequest) Reset()

func (*GetRecordsRequest) String 

func (x *GetRecordsRequest) String() string

type GetRecordsResponse 

type GetRecordsResponse struct {
	Records []*log.LogRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecordsResponse) Descriptor deprecated 

func (*GetRecordsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRecordsResponse.ProtoReflect.Descriptor instead.

func (*GetRecordsResponse) GetRecords 

func (x *GetRecordsResponse) GetRecords() []*log.LogRecord

func (*GetRecordsResponse) ProtoMessage 

func (*GetRecordsResponse) ProtoMessage()

func (*GetRecordsResponse) ProtoReflect 

func (x *GetRecordsResponse) ProtoReflect() protoreflect.Message

func (*GetRecordsResponse) Reset 

func (x *GetRecordsResponse) Reset()

func (*GetRecordsResponse) String 

func (x *GetRecordsResponse) String() string

type GetStatusSummaryRequest 

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

func (*GetStatusSummaryRequest) Descriptor deprecated 

func (*GetStatusSummaryRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStatusSummaryRequest.ProtoReflect.Descriptor instead.

func (*GetStatusSummaryRequest) ProtoMessage 

func (*GetStatusSummaryRequest) ProtoMessage()

func (*GetStatusSummaryRequest) ProtoReflect 

func (x *GetStatusSummaryRequest) ProtoReflect() protoreflect.Message

func (*GetStatusSummaryRequest) Reset 

func (x *GetStatusSummaryRequest) Reset()

func (*GetStatusSummaryRequest) String 

func (x *GetStatusSummaryRequest) String() string

type GetStatusSummaryResponse 

type GetStatusSummaryResponse struct {
	CompletedActionStats map[string]int32 `` /* 212-byte string literal not displayed */
	RunningActions       int32            `protobuf:"varint,2,opt,name=running_actions,json=runningActions,proto3" json:"running_actions,omitempty"`
	Qps                  int32            `protobuf:"varint,3,opt,name=qps,proto3" json:"qps,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusSummaryResponse) Descriptor deprecated 

func (*GetStatusSummaryResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetStatusSummaryResponse.ProtoReflect.Descriptor instead.

func (*GetStatusSummaryResponse) GetCompletedActionStats 

func (x *GetStatusSummaryResponse) GetCompletedActionStats() map[string]int32

func (*GetStatusSummaryResponse) GetQps 

func (x *GetStatusSummaryResponse) GetQps() int32

func (*GetStatusSummaryResponse) GetRunningActions 

func (x *GetStatusSummaryResponse) GetRunningActions() int32

func (*GetStatusSummaryResponse) ProtoMessage 

func (*GetStatusSummaryResponse) ProtoMessage()

func (*GetStatusSummaryResponse) ProtoReflect 

func (x *GetStatusSummaryResponse) ProtoReflect() protoreflect.Message

func (*GetStatusSummaryResponse) Reset 

func (x *GetStatusSummaryResponse) Reset()

func (*GetStatusSummaryResponse) String 

func (x *GetStatusSummaryResponse) String() string

type LocalExecutionOptions 

type LocalExecutionOptions struct {
	Platform     LocalExecutionOptions_LocalExecutionPlatform `` /* 126-byte string literal not displayed */
	DoNotCache   bool                                         `protobuf:"varint,2,opt,name=do_not_cache,json=doNotCache,proto3" json:"do_not_cache,omitempty"`
	AcceptCached bool                                         `protobuf:"varint,3,opt,name=accept_cached,json=acceptCached,proto3" json:"accept_cached,omitempty"`
	Wrapper      string                                       `protobuf:"bytes,4,opt,name=wrapper,proto3" json:"wrapper,omitempty"`
	// contains filtered or unexported fields
}

func (*LocalExecutionOptions) Descriptor deprecated 

func (*LocalExecutionOptions) Descriptor() ([]byte, []int)

Deprecated: Use LocalExecutionOptions.ProtoReflect.Descriptor instead.

func (*LocalExecutionOptions) GetAcceptCached 

func (x *LocalExecutionOptions) GetAcceptCached() bool

func (*LocalExecutionOptions) GetDoNotCache 

func (x *LocalExecutionOptions) GetDoNotCache() bool

func (*LocalExecutionOptions) GetPlatform 

func (x *LocalExecutionOptions) GetPlatform() LocalExecutionOptions_LocalExecutionPlatform

func (*LocalExecutionOptions) GetWrapper 

func (x *LocalExecutionOptions) GetWrapper() string

func (*LocalExecutionOptions) ProtoMessage 

func (*LocalExecutionOptions) ProtoMessage()

func (*LocalExecutionOptions) ProtoReflect 

func (x *LocalExecutionOptions) ProtoReflect() protoreflect.Message

func (*LocalExecutionOptions) Reset 

func (x *LocalExecutionOptions) Reset()

func (*LocalExecutionOptions) String 

func (x *LocalExecutionOptions) String() string

type LocalExecutionOptions_LocalExecutionPlatform 

type LocalExecutionOptions_LocalExecutionPlatform int32
const (
	LocalExecutionOptions_UNSPECIFIED LocalExecutionOptions_LocalExecutionPlatform = 0
	LocalExecutionOptions_DOCKER      LocalExecutionOptions_LocalExecutionPlatform = 1
)

func (LocalExecutionOptions_LocalExecutionPlatform) Descriptor 

func (LocalExecutionOptions_LocalExecutionPlatform) Descriptor() protoreflect.EnumDescriptor

func (LocalExecutionOptions_LocalExecutionPlatform) Enum 

func (x LocalExecutionOptions_LocalExecutionPlatform) Enum() *LocalExecutionOptions_LocalExecutionPlatform

func (LocalExecutionOptions_LocalExecutionPlatform) EnumDescriptor deprecated 

func (LocalExecutionOptions_LocalExecutionPlatform) EnumDescriptor() ([]byte, []int)

Deprecated: Use LocalExecutionOptions_LocalExecutionPlatform.Descriptor instead.

func (LocalExecutionOptions_LocalExecutionPlatform) Number 

func (x LocalExecutionOptions_LocalExecutionPlatform) Number() protoreflect.EnumNumber

func (LocalExecutionOptions_LocalExecutionPlatform) String 

func (x LocalExecutionOptions_LocalExecutionPlatform) String() string

func (LocalExecutionOptions_LocalExecutionPlatform) Type 

func (LocalExecutionOptions_LocalExecutionPlatform) Type() protoreflect.EnumType

type Metadata 

type Metadata struct {
	EventTimes  map[string]*command.TimeInterval `` /* 179-byte string literal not displayed */
	Environment []string                         `protobuf:"bytes,2,rep,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

func (*Metadata) Descriptor() ([]byte, []int)

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetEnvironment 

func (x *Metadata) GetEnvironment() []string

func (*Metadata) GetEventTimes 

func (x *Metadata) GetEventTimes() map[string]*command.TimeInterval

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type MismatchIgnoreConfig 

type MismatchIgnoreConfig struct {
	Rules []*Rule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

func (*MismatchIgnoreConfig) Descriptor deprecated 

func (*MismatchIgnoreConfig) Descriptor() ([]byte, []int)

Deprecated: Use MismatchIgnoreConfig.ProtoReflect.Descriptor instead.

func (*MismatchIgnoreConfig) GetRules 

func (x *MismatchIgnoreConfig) GetRules() []*Rule

func (*MismatchIgnoreConfig) ProtoMessage 

func (*MismatchIgnoreConfig) ProtoMessage()

func (*MismatchIgnoreConfig) ProtoReflect 

func (x *MismatchIgnoreConfig) ProtoReflect() protoreflect.Message

func (*MismatchIgnoreConfig) Reset 

func (x *MismatchIgnoreConfig) Reset()

func (*MismatchIgnoreConfig) String 

func (x *MismatchIgnoreConfig) String() string

type OutputFilePathRuleSpec 

type OutputFilePathRuleSpec struct {
	PathPattern *RegexPattern `protobuf:"bytes,1,opt,name=path_pattern,json=pathPattern,proto3" json:"path_pattern,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputFilePathRuleSpec) Descriptor deprecated 

func (*OutputFilePathRuleSpec) Descriptor() ([]byte, []int)

Deprecated: Use OutputFilePathRuleSpec.ProtoReflect.Descriptor instead.

func (*OutputFilePathRuleSpec) GetPathPattern 

func (x *OutputFilePathRuleSpec) GetPathPattern() *RegexPattern

func (*OutputFilePathRuleSpec) ProtoMessage 

func (*OutputFilePathRuleSpec) ProtoMessage()

func (*OutputFilePathRuleSpec) ProtoReflect 

func (x *OutputFilePathRuleSpec) ProtoReflect() protoreflect.Message

func (*OutputFilePathRuleSpec) Reset 

func (x *OutputFilePathRuleSpec) Reset()

func (*OutputFilePathRuleSpec) String 

func (x *OutputFilePathRuleSpec) String() string

type ProxyExecutionOptions 

type ProxyExecutionOptions struct {
	ExecutionStrategy      ExecutionStrategy_Value `` /* 148-byte string literal not displayed */
	RemoteExecutionOptions *RemoteExecutionOptions `` /* 129-byte string literal not displayed */
	LocalExecutionOptions  *LocalExecutionOptions  `` /* 126-byte string literal not displayed */
	CompareWithLocal       bool                    `protobuf:"varint,4,opt,name=compare_with_local,json=compareWithLocal,proto3" json:"compare_with_local,omitempty"`
	NumRetriesIfMismatched int32                   `` /* 132-byte string literal not displayed */
	NumLocalReruns         int32                   `protobuf:"varint,6,opt,name=num_local_reruns,json=numLocalReruns,proto3" json:"num_local_reruns,omitempty"`
	NumRemoteReruns        int32                   `protobuf:"varint,7,opt,name=num_remote_reruns,json=numRemoteReruns,proto3" json:"num_remote_reruns,omitempty"`
	LogEnvironment         bool                    `protobuf:"varint,8,opt,name=log_environment,json=logEnvironment,proto3" json:"log_environment,omitempty"`
	IncludeActionLog       bool                    `protobuf:"varint,9,opt,name=include_action_log,json=includeActionLog,proto3" json:"include_action_log,omitempty"`
	ReclientTimeout        int32                   `protobuf:"varint,10,opt,name=reclient_timeout,json=reclientTimeout,proto3" json:"reclient_timeout,omitempty"`
	EnableAtomicDownloads  bool                    `` /* 128-byte string literal not displayed */
	DownloadRegex          string                  `protobuf:"bytes,12,opt,name=download_regex,json=downloadRegex,proto3" json:"download_regex,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyExecutionOptions) Descriptor deprecated 

func (*ProxyExecutionOptions) Descriptor() ([]byte, []int)

Deprecated: Use ProxyExecutionOptions.ProtoReflect.Descriptor instead.

func (*ProxyExecutionOptions) GetCompareWithLocal 

func (x *ProxyExecutionOptions) GetCompareWithLocal() bool

func (*ProxyExecutionOptions) GetDownloadRegex 

func (x *ProxyExecutionOptions) GetDownloadRegex() string

func (*ProxyExecutionOptions) GetEnableAtomicDownloads 

func (x *ProxyExecutionOptions) GetEnableAtomicDownloads() bool

func (*ProxyExecutionOptions) GetExecutionStrategy 

func (x *ProxyExecutionOptions) GetExecutionStrategy() ExecutionStrategy_Value

func (*ProxyExecutionOptions) GetIncludeActionLog 

func (x *ProxyExecutionOptions) GetIncludeActionLog() bool

func (*ProxyExecutionOptions) GetLocalExecutionOptions 

func (x *ProxyExecutionOptions) GetLocalExecutionOptions() *LocalExecutionOptions

func (*ProxyExecutionOptions) GetLogEnvironment 

func (x *ProxyExecutionOptions) GetLogEnvironment() bool

func (*ProxyExecutionOptions) GetNumLocalReruns 

func (x *ProxyExecutionOptions) GetNumLocalReruns() int32

func (*ProxyExecutionOptions) GetNumRemoteReruns 

func (x *ProxyExecutionOptions) GetNumRemoteReruns() int32

func (*ProxyExecutionOptions) GetNumRetriesIfMismatched 

func (x *ProxyExecutionOptions) GetNumRetriesIfMismatched() int32

func (*ProxyExecutionOptions) GetReclientTimeout 

func (x *ProxyExecutionOptions) GetReclientTimeout() int32

func (*ProxyExecutionOptions) GetRemoteExecutionOptions 

func (x *ProxyExecutionOptions) GetRemoteExecutionOptions() *RemoteExecutionOptions

func (*ProxyExecutionOptions) ProtoMessage 

func (*ProxyExecutionOptions) ProtoMessage()

func (*ProxyExecutionOptions) ProtoReflect 

func (x *ProxyExecutionOptions) ProtoReflect() protoreflect.Message

func (*ProxyExecutionOptions) Reset 

func (x *ProxyExecutionOptions) Reset()

func (*ProxyExecutionOptions) String 

func (x *ProxyExecutionOptions) String() string

type RegexPattern 

type RegexPattern struct {
	Expression string `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
	Inverted   bool   `protobuf:"varint,2,opt,name=inverted,proto3" json:"inverted,omitempty"`
	// contains filtered or unexported fields
}

func (*RegexPattern) Descriptor deprecated 

func (*RegexPattern) Descriptor() ([]byte, []int)

Deprecated: Use RegexPattern.ProtoReflect.Descriptor instead.

func (*RegexPattern) GetExpression 

func (x *RegexPattern) GetExpression() string

func (*RegexPattern) GetInverted 

func (x *RegexPattern) GetInverted() bool

func (*RegexPattern) ProtoMessage 

func (*RegexPattern) ProtoMessage()

func (*RegexPattern) ProtoReflect 

func (x *RegexPattern) ProtoReflect() protoreflect.Message

func (*RegexPattern) Reset 

func (x *RegexPattern) Reset()

func (*RegexPattern) String 

func (x *RegexPattern) String() string

type RemoteExecutionOptions 

type RemoteExecutionOptions struct {
	AcceptCached                 bool   `protobuf:"varint,1,opt,name=accept_cached,json=acceptCached,proto3" json:"accept_cached,omitempty"`
	DoNotCache                   bool   `protobuf:"varint,2,opt,name=do_not_cache,json=doNotCache,proto3" json:"do_not_cache,omitempty"`
	DownloadOutputs              bool   `protobuf:"varint,3,opt,name=download_outputs,json=downloadOutputs,proto3" json:"download_outputs,omitempty"`
	Wrapper                      string `protobuf:"bytes,5,opt,name=wrapper,proto3" json:"wrapper,omitempty"`
	CanonicalizeWorkingDir       bool   `` /* 130-byte string literal not displayed */
	PreserveUnchangedOutputMtime bool   `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RemoteExecutionOptions) Descriptor deprecated 

func (*RemoteExecutionOptions) Descriptor() ([]byte, []int)

Deprecated: Use RemoteExecutionOptions.ProtoReflect.Descriptor instead.

func (*RemoteExecutionOptions) GetAcceptCached 

func (x *RemoteExecutionOptions) GetAcceptCached() bool

func (*RemoteExecutionOptions) GetCanonicalizeWorkingDir 

func (x *RemoteExecutionOptions) GetCanonicalizeWorkingDir() bool

func (*RemoteExecutionOptions) GetDoNotCache 

func (x *RemoteExecutionOptions) GetDoNotCache() bool

func (*RemoteExecutionOptions) GetDownloadOutputs 

func (x *RemoteExecutionOptions) GetDownloadOutputs() bool

func (*RemoteExecutionOptions) GetPreserveUnchangedOutputMtime 

func (x *RemoteExecutionOptions) GetPreserveUnchangedOutputMtime() bool

func (*RemoteExecutionOptions) GetWrapper 

func (x *RemoteExecutionOptions) GetWrapper() string

func (*RemoteExecutionOptions) ProtoMessage 

func (*RemoteExecutionOptions) ProtoMessage()

func (*RemoteExecutionOptions) ProtoReflect 

func (x *RemoteExecutionOptions) ProtoReflect() protoreflect.Message

func (*RemoteExecutionOptions) Reset 

func (x *RemoteExecutionOptions) Reset()

func (*RemoteExecutionOptions) String 

func (x *RemoteExecutionOptions) String() string

type RemoteFallbackInfo 

type RemoteFallbackInfo struct {
	ExitCode int32  `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Stdout   []byte `protobuf:"bytes,2,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr   []byte `protobuf:"bytes,3,opt,name=stderr,proto3" json:"stderr,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteFallbackInfo) Descriptor deprecated 

func (*RemoteFallbackInfo) Descriptor() ([]byte, []int)

Deprecated: Use RemoteFallbackInfo.ProtoReflect.Descriptor instead.

func (*RemoteFallbackInfo) GetExitCode 

func (x *RemoteFallbackInfo) GetExitCode() int32

func (*RemoteFallbackInfo) GetStderr 

func (x *RemoteFallbackInfo) GetStderr() []byte

func (*RemoteFallbackInfo) GetStdout 

func (x *RemoteFallbackInfo) GetStdout() []byte

func (*RemoteFallbackInfo) ProtoMessage 

func (*RemoteFallbackInfo) ProtoMessage()

func (*RemoteFallbackInfo) ProtoReflect 

func (x *RemoteFallbackInfo) ProtoReflect() protoreflect.Message

func (*RemoteFallbackInfo) Reset 

func (x *RemoteFallbackInfo) Reset()

func (*RemoteFallbackInfo) String 

func (x *RemoteFallbackInfo) String() string

type Rule 

type Rule struct {

	// Types that are assignable to RuleSpec:
	//
	//	*Rule_OutputFilePathRuleSpec
	RuleSpec isRule_RuleSpec `protobuf_oneof:"rule_spec"`
	// contains filtered or unexported fields
}

func (*Rule) Descriptor deprecated 

func (*Rule) Descriptor() ([]byte, []int)

Deprecated: Use Rule.ProtoReflect.Descriptor instead.

func (*Rule) GetOutputFilePathRuleSpec 

func (x *Rule) GetOutputFilePathRuleSpec() *OutputFilePathRuleSpec

func (*Rule) GetRuleSpec 

func (m *Rule) GetRuleSpec() isRule_RuleSpec

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) ProtoReflect 

func (x *Rule) ProtoReflect() protoreflect.Message

func (*Rule) Reset 

func (x *Rule) Reset()

func (*Rule) String 

func (x *Rule) String() string

type Rule_OutputFilePathRuleSpec 

type Rule_OutputFilePathRuleSpec struct {
	OutputFilePathRuleSpec *OutputFilePathRuleSpec `protobuf:"bytes,1,opt,name=output_file_path_rule_spec,json=outputFilePathRuleSpec,proto3,oneof"`
}

type RunRequest 

type RunRequest struct {
	Command          *command.Command       `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Labels           map[string]string      `` /* 153-byte string literal not displayed */
	ExecutionOptions *ProxyExecutionOptions `protobuf:"bytes,3,opt,name=execution_options,json=executionOptions,proto3" json:"execution_options,omitempty"`
	Metadata         *Metadata              `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ToolchainInputs  []string               `protobuf:"bytes,5,rep,name=toolchain_inputs,json=toolchainInputs,proto3" json:"toolchain_inputs,omitempty"`
	// contains filtered or unexported fields
}

func (*RunRequest) Descriptor deprecated 

func (*RunRequest) Descriptor() ([]byte, []int)

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) GetCommand 

func (x *RunRequest) GetCommand() *command.Command

func (*RunRequest) GetExecutionOptions 

func (x *RunRequest) GetExecutionOptions() *ProxyExecutionOptions

func (*RunRequest) GetLabels 

func (x *RunRequest) GetLabels() map[string]string

func (*RunRequest) GetMetadata 

func (x *RunRequest) GetMetadata() *Metadata

func (*RunRequest) GetToolchainInputs 

func (x *RunRequest) GetToolchainInputs() []string

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect 

func (x *RunRequest) ProtoReflect() protoreflect.Message

func (*RunRequest) Reset 

func (x *RunRequest) Reset()

func (*RunRequest) String 

func (x *RunRequest) String() string

type RunResponse 

type RunResponse struct {
	Stdout             []byte                 `protobuf:"bytes,1,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr             []byte                 `protobuf:"bytes,2,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Result             *command.CommandResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	ExecutionId        string                 `protobuf:"bytes,4,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	ActionLog          *log.LogRecord         `protobuf:"bytes,5,opt,name=action_log,json=actionLog,proto3" json:"action_log,omitempty"`
	RemoteFallbackInfo *RemoteFallbackInfo    `protobuf:"bytes,6,opt,name=remote_fallback_info,json=remoteFallbackInfo,proto3" json:"remote_fallback_info,omitempty"`
	// contains filtered or unexported fields
}

func (*RunResponse) Descriptor deprecated 

func (*RunResponse) Descriptor() ([]byte, []int)

Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.

func (*RunResponse) GetActionLog 

func (x *RunResponse) GetActionLog() *log.LogRecord

func (*RunResponse) GetExecutionId 

func (x *RunResponse) GetExecutionId() string

func (*RunResponse) GetRemoteFallbackInfo 

func (x *RunResponse) GetRemoteFallbackInfo() *RemoteFallbackInfo

func (*RunResponse) GetResult 

func (x *RunResponse) GetResult() *command.CommandResult

func (*RunResponse) GetStderr 

func (x *RunResponse) GetStderr() []byte

func (*RunResponse) GetStdout 

func (x *RunResponse) GetStdout() []byte

func (*RunResponse) ProtoMessage 

func (*RunResponse) ProtoMessage()

func (*RunResponse) ProtoReflect 

func (x *RunResponse) ProtoReflect() protoreflect.Message

func (*RunResponse) Reset 

func (x *RunResponse) Reset()

func (*RunResponse) String 

func (x *RunResponse) String() string

type ShutdownRequest 

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

func (*ShutdownRequest) Descriptor deprecated 

func (*ShutdownRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

func (x *ShutdownRequest) ProtoReflect() protoreflect.Message

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type ShutdownResponse 

type ShutdownResponse struct {
	Stats *stats.Stats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*ShutdownResponse) Descriptor deprecated 

func (*ShutdownResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) GetStats 

func (x *ShutdownResponse) GetStats() *stats.Stats

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect 

func (x *ShutdownResponse) ProtoReflect() protoreflect.Message

func (*ShutdownResponse) Reset 

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (x *ShutdownResponse) String() string

type StatsClient 

type StatsClient interface {
	GetRecords(ctx context.Context, in *GetRecordsRequest, opts ...grpc.CallOption) (*GetRecordsResponse, error)
	AddProxyEvents(ctx context.Context, in *AddProxyEventsRequest, opts ...grpc.CallOption) (*AddProxyEventsResponse, error)
}

StatsClient is the client API for Stats service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStatsClient 

func NewStatsClient(cc grpc.ClientConnInterface) StatsClient

type StatsServer 

type StatsServer interface {
	GetRecords(context.Context, *GetRecordsRequest) (*GetRecordsResponse, error)
	AddProxyEvents(context.Context, *AddProxyEventsRequest) (*AddProxyEventsResponse, error)
}

StatsServer is the server API for Stats service.

type StatusClient 

type StatusClient interface {
	GetStatusSummary(ctx context.Context, in *GetStatusSummaryRequest, opts ...grpc.CallOption) (*GetStatusSummaryResponse, error)
}

StatusClient is the client API for Status service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStatusClient 

func NewStatusClient(cc grpc.ClientConnInterface) StatusClient

type StatusServer 

type StatusServer interface {
	GetStatusSummary(context.Context, *GetStatusSummaryRequest) (*GetStatusSummaryResponse, error)
}

StatusServer is the server API for Status service.

type UnimplementedCommandsServer 

type UnimplementedCommandsServer struct {
}

UnimplementedCommandsServer can be embedded to have forward compatible implementations.

func (*UnimplementedCommandsServer) RunCommand 

func (*UnimplementedCommandsServer) RunCommand(context.Context, *RunRequest) (*RunResponse, error)

func (*UnimplementedCommandsServer) Shutdown 

func (*UnimplementedCommandsServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)

type UnimplementedStatsServer 

type UnimplementedStatsServer struct {
}

UnimplementedStatsServer can be embedded to have forward compatible implementations.

func (*UnimplementedStatsServer) AddProxyEvents 

func (*UnimplementedStatsServer) AddProxyEvents(context.Context, *AddProxyEventsRequest) (*AddProxyEventsResponse, error)

func (*UnimplementedStatsServer) GetRecords 

func (*UnimplementedStatsServer) GetRecords(context.Context, *GetRecordsRequest) (*GetRecordsResponse, error)

type UnimplementedStatusServer 

type UnimplementedStatusServer struct {
}

UnimplementedStatusServer can be embedded to have forward compatible implementations.

func (*UnimplementedStatusServer) GetStatusSummary 

func (*UnimplementedStatusServer) GetStatusSummary(context.Context, *GetStatusSummaryRequest) (*GetStatusSummaryResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.