result_flow

package
v0.0.0-...-6bac870 Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2021 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "SUCCEEDED",
		2: "FAILED",
		3: "TIMED_OUT",
		4: "ABORTED",
	}
	State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"SUCCEEDED":         1,
		"FAILED":            2,
		"TIMED_OUT":         3,
		"ABORTED":           4,
	}
)

Enum value maps for State.

View Source 
var File_test_platform_result_flow_common_proto protoreflect.FileDescriptor
View Source 
var File_test_platform_result_flow_ctp_proto protoreflect.FileDescriptor
View Source 
var File_test_platform_result_flow_publish_proto protoreflect.FileDescriptor
View Source 
var File_test_platform_result_flow_test_runner_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BigqueryConfig 

type BigqueryConfig struct {
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Dataset string `protobuf:"bytes,2,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Table   string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

BigqueryConfig contains the config to interact with Bigquery.

func (*BigqueryConfig) Descriptor deprecated 

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

Deprecated: Use BigqueryConfig.ProtoReflect.Descriptor instead.

func (*BigqueryConfig) GetDataset 

func (x *BigqueryConfig) GetDataset() string

func (*BigqueryConfig) GetProject 

func (x *BigqueryConfig) GetProject() string

func (*BigqueryConfig) GetTable 

func (x *BigqueryConfig) GetTable() string

func (*BigqueryConfig) ProtoMessage 

func (*BigqueryConfig) ProtoMessage()

func (*BigqueryConfig) ProtoReflect 

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

func (*BigqueryConfig) Reset 

func (x *BigqueryConfig) Reset()

func (*BigqueryConfig) String 

func (x *BigqueryConfig) String() string

type BuildbucketConfig 

type BuildbucketConfig struct {
	Host    string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	Bucket  string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Builder string `protobuf:"bytes,4,opt,name=builder,proto3" json:"builder,omitempty"`
	// contains filtered or unexported fields
}

BuildbucketConfig contains the config to interact with Buildbucket.

func (*BuildbucketConfig) Descriptor deprecated 

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

Deprecated: Use BuildbucketConfig.ProtoReflect.Descriptor instead.

func (*BuildbucketConfig) GetBucket 

func (x *BuildbucketConfig) GetBucket() string

func (*BuildbucketConfig) GetBuilder 

func (x *BuildbucketConfig) GetBuilder() string

func (*BuildbucketConfig) GetHost 

func (x *BuildbucketConfig) GetHost() string

func (*BuildbucketConfig) GetProject 

func (x *BuildbucketConfig) GetProject() string

func (*BuildbucketConfig) ProtoMessage 

func (*BuildbucketConfig) ProtoMessage()

func (*BuildbucketConfig) ProtoReflect 

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

func (*BuildbucketConfig) Reset 

func (x *BuildbucketConfig) Reset()

func (*BuildbucketConfig) String 

func (x *BuildbucketConfig) String() string

type CTPRequest 

type CTPRequest struct {

	// The source config for fetching a CTP build.
	Ctp *Source `protobuf:"bytes,1,opt,name=ctp,proto3" json:"ctp,omitempty"`
	// The target to upload the result flow output.
	TestPlanRun *Target `protobuf:"bytes,2,opt,name=test_plan_run,json=testPlanRun,proto3" json:"test_plan_run,omitempty"`
	// Hard deadline for execution.
	//
	// CTP command should abort beyond this deadline.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// contains filtered or unexported fields
}

CTPRequest defines the input of `result_flow ctp`.

func (*CTPRequest) Descriptor deprecated 

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

Deprecated: Use CTPRequest.ProtoReflect.Descriptor instead.

func (*CTPRequest) GetCtp 

func (x *CTPRequest) GetCtp() *Source

func (*CTPRequest) GetDeadline 

func (x *CTPRequest) GetDeadline() *timestamppb.Timestamp

func (*CTPRequest) GetTestPlanRun 

func (x *CTPRequest) GetTestPlanRun() *Target

func (*CTPRequest) ProtoMessage 

func (*CTPRequest) ProtoMessage()

func (*CTPRequest) ProtoReflect 

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

func (*CTPRequest) Reset 

func (x *CTPRequest) Reset()

func (*CTPRequest) String 

func (x *CTPRequest) String() string

type CTPResponse 

type CTPResponse struct {

	// `result_flow ctp` exits with exit code 0 unless there is an
	// infrastructure failure. When the exit code is 0, `state` indicates the
	// best known state of the ctp command execution (see comments on State enum).
	State State `protobuf:"varint,1,opt,name=state,proto3,enum=test_platform.result_flow.State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

CTPResponse defines the output of `result_flow ctp`.

func (*CTPResponse) Descriptor deprecated 

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

Deprecated: Use CTPResponse.ProtoReflect.Descriptor instead.

func (*CTPResponse) GetState 

func (x *CTPResponse) GetState() State

func (*CTPResponse) ProtoMessage 

func (*CTPResponse) ProtoMessage()

func (*CTPResponse) ProtoReflect 

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

func (*CTPResponse) Reset 

func (x *CTPResponse) Reset()

func (*CTPResponse) String 

func (x *CTPResponse) String() string

type PubSubConfig 

type PubSubConfig struct {
	Project              string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Topic                string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Subscription         string `protobuf:"bytes,3,opt,name=subscription,proto3" json:"subscription,omitempty"`
	MaxReceivingMessages int32  `protobuf:"varint,4,opt,name=max_receiving_messages,json=maxReceivingMessages,proto3" json:"max_receiving_messages,omitempty"`
	// contains filtered or unexported fields
}

PubSubConfig contains the config to interact with Pub/Sub.

func (*PubSubConfig) Descriptor deprecated 

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

Deprecated: Use PubSubConfig.ProtoReflect.Descriptor instead.

func (*PubSubConfig) GetMaxReceivingMessages 

func (x *PubSubConfig) GetMaxReceivingMessages() int32

func (*PubSubConfig) GetProject 

func (x *PubSubConfig) GetProject() string

func (*PubSubConfig) GetSubscription 

func (x *PubSubConfig) GetSubscription() string

func (*PubSubConfig) GetTopic 

func (x *PubSubConfig) GetTopic() string

func (*PubSubConfig) ProtoMessage 

func (*PubSubConfig) ProtoMessage()

func (*PubSubConfig) ProtoReflect 

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

func (*PubSubConfig) Reset 

func (x *PubSubConfig) Reset()

func (*PubSubConfig) String 

func (x *PubSubConfig) String() string

type PublishRequest 

type PublishRequest struct {

	// Subscribers call Buildbucket to fetch the build information via this ID.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// Should not be used, as the parent CTP build may contain multiple TestPlanRuns.
	// Use parent_uid below.
	//
	// Deprecated: Do not use.
	ParentBuildId int64 `protobuf:"varint,2,opt,name=parent_build_id,json=parentBuildId,proto3" json:"parent_build_id,omitempty"`
	// PubSub endpoint to publish a CTP build.
	Ctp *PubSubConfig `protobuf:"bytes,3,opt,name=ctp,proto3" json:"ctp,omitempty"`
	// PubSub endpoint to publish a test runner build.
	TestRunner *PubSubConfig `protobuf:"bytes,4,opt,name=test_runner,json=testRunner,proto3" json:"test_runner,omitempty"`
	// Hard deadline for execution.
	//
	// Publish command should abort beyond this deadline.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// True if subscribers should fetch the build's final status from
	// Buildbucket. The message may be earlier than the build's completion. If
	// the Buildbucket's response does not contain its final status, subscribers
	// should retry. Otherwise, subscribers should expect an intermediate status
	// of the build.
	ShouldPollForCompletion bool `` /* 135-byte string literal not displayed */
	// The UID of the parent test plan run, which kicks off this test run.
	// Placed inside the pubsub message for test_runner builds.
	ParentUid string `protobuf:"bytes,7,opt,name=parent_uid,json=parentUid,proto3" json:"parent_uid,omitempty"`
	// contains filtered or unexported fields
}

PublishRequest defines the input of `result_flow publish`.

func (*PublishRequest) Descriptor deprecated 

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetBuildId 

func (x *PublishRequest) GetBuildId() int64

func (*PublishRequest) GetCtp 

func (x *PublishRequest) GetCtp() *PubSubConfig

func (*PublishRequest) GetDeadline 

func (x *PublishRequest) GetDeadline() *timestamppb.Timestamp

func (*PublishRequest) GetParentBuildId deprecated 

func (x *PublishRequest) GetParentBuildId() int64

Deprecated: Do not use.

func (*PublishRequest) GetParentUid 

func (x *PublishRequest) GetParentUid() string

func (*PublishRequest) GetShouldPollForCompletion 

func (x *PublishRequest) GetShouldPollForCompletion() bool

func (*PublishRequest) GetTestRunner 

func (x *PublishRequest) GetTestRunner() *PubSubConfig

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect 

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

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) String 

func (x *PublishRequest) String() string

type PublishResponse 

type PublishResponse struct {

	// `result_flow publish` exits with exit code 0 unless there is an
	// infrastructure failure. When the exit code is 0, `state` indicates the
	// best known state of the publish execution (see comments on State enum).
	State State `protobuf:"varint,1,opt,name=state,proto3,enum=test_platform.result_flow.State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

PublishRequest defines the output of `result_flow publish`.

func (*PublishResponse) Descriptor deprecated 

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetState 

func (x *PublishResponse) GetState() State

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect 

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

func (*PublishResponse) Reset 

func (x *PublishResponse) Reset()

func (*PublishResponse) String 

func (x *PublishResponse) String() string

type Source 

type Source struct {
	Pubsub *PubSubConfig      `protobuf:"bytes,1,opt,name=pubsub,proto3" json:"pubsub,omitempty"`
	Bb     *BuildbucketConfig `protobuf:"bytes,2,opt,name=bb,proto3" json:"bb,omitempty"`
	Fields []string           `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

Source is a wrapper for the source side configuration.

func (*Source) Descriptor deprecated 

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

Deprecated: Use Source.ProtoReflect.Descriptor instead.

func (*Source) GetBb 

func (x *Source) GetBb() *BuildbucketConfig

func (*Source) GetFields 

func (x *Source) GetFields() []string

func (*Source) GetPubsub 

func (x *Source) GetPubsub() *PubSubConfig

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoReflect 

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

func (*Source) Reset 

func (x *Source) Reset()

func (*Source) String 

func (x *Source) String() string

type State 

type State int32

Values should be consistent with https://aip.dev/216 

const (
	// Should not be used.
	State_STATE_UNSPECIFIED State = 0
	// Successfully executed the command.
	State_SUCCEEDED State = 1
	// Encountered failure during the run.
	State_FAILED State = 2
	// The command has hit the predefined deadline.
	State_TIMED_OUT State = 3
	// The command was aborted externally.
	State_ABORTED State = 4
)

func (State) Descriptor 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

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

Deprecated: Use State.Descriptor instead.

func (State) Number 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type 

func (State) Type() protoreflect.EnumType

type Target 

type Target struct {
	Bq *BigqueryConfig `protobuf:"bytes,1,opt,name=bq,proto3" json:"bq,omitempty"`
	// contains filtered or unexported fields
}

Target is a wrapper for the target side configuration.

func (*Target) Descriptor deprecated 

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

Deprecated: Use Target.ProtoReflect.Descriptor instead.

func (*Target) GetBq 

func (x *Target) GetBq() *BigqueryConfig

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) ProtoReflect 

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

func (*Target) Reset 

func (x *Target) Reset()

func (*Target) String 

func (x *Target) String() string

type TestRunnerRequest 

type TestRunnerRequest struct {

	// The source config for fetching the test runner builds.
	TestRunner *Source `protobuf:"bytes,1,opt,name=test_runner,json=testRunner,proto3" json:"test_runner,omitempty"`
	// The target to upload test run results.
	TestRun *Target `protobuf:"bytes,2,opt,name=test_run,json=testRun,proto3" json:"test_run,omitempty"`
	// The target to upload test case results.
	TestCase *Target `protobuf:"bytes,3,opt,name=test_case,json=testCase,proto3" json:"test_case,omitempty"`
	// Hard deadline for execution.
	//
	// TestRunner command should abort beyond this deadline.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// contains filtered or unexported fields
}

TestRunnerRequest defines the input of `result_flow test_runner`.

func (*TestRunnerRequest) Descriptor deprecated 

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

Deprecated: Use TestRunnerRequest.ProtoReflect.Descriptor instead.

func (*TestRunnerRequest) GetDeadline 

func (x *TestRunnerRequest) GetDeadline() *timestamppb.Timestamp

func (*TestRunnerRequest) GetTestCase 

func (x *TestRunnerRequest) GetTestCase() *Target

func (*TestRunnerRequest) GetTestRun 

func (x *TestRunnerRequest) GetTestRun() *Target

func (*TestRunnerRequest) GetTestRunner 

func (x *TestRunnerRequest) GetTestRunner() *Source

func (*TestRunnerRequest) ProtoMessage 

func (*TestRunnerRequest) ProtoMessage()

func (*TestRunnerRequest) ProtoReflect 

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

func (*TestRunnerRequest) Reset 

func (x *TestRunnerRequest) Reset()

func (*TestRunnerRequest) String 

func (x *TestRunnerRequest) String() string

type TestRunnerResponse 

type TestRunnerResponse struct {

	// `result_flow test_runner` exits with exit code 0 unless there is an
	// infrastructure failure. When the exit code is 0, `state` indicates the
	// best known state of the test_runner command execution (see comments on State enum).
	State State `protobuf:"varint,1,opt,name=state,proto3,enum=test_platform.result_flow.State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

TestRunnerResponse defines the output of `result_flow test_runner`.

func (*TestRunnerResponse) Descriptor deprecated 

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

Deprecated: Use TestRunnerResponse.ProtoReflect.Descriptor instead.

func (*TestRunnerResponse) GetState 

func (x *TestRunnerResponse) GetState() State

func (*TestRunnerResponse) ProtoMessage 

func (*TestRunnerResponse) ProtoMessage()

func (*TestRunnerResponse) ProtoReflect 

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

func (*TestRunnerResponse) Reset 

func (x *TestRunnerResponse) Reset()

func (*TestRunnerResponse) String 

func (x *TestRunnerResponse) String() string

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.