proto: go.chromium.org/chromiumos/infra/proto/go/test_platform/result_flow Index | Files

package result_flow

import "go.chromium.org/chromiumos/infra/proto/go/test_platform/result_flow"

Index

Package Files

common.pb.go ctp.pb.go publish.pb.go test_runner.pb.go

Variables

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

type BigqueryConfig Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

BigqueryConfig contains the config to interact with Bigquery.

func (*BigqueryConfig) Descriptor Uses

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

func (*BigqueryConfig) GetDataset Uses

func (m *BigqueryConfig) GetDataset() string

func (*BigqueryConfig) GetProject Uses

func (m *BigqueryConfig) GetProject() string

func (*BigqueryConfig) GetTable Uses

func (m *BigqueryConfig) GetTable() string

func (*BigqueryConfig) ProtoMessage Uses

func (*BigqueryConfig) ProtoMessage()

func (*BigqueryConfig) Reset Uses

func (m *BigqueryConfig) Reset()

func (*BigqueryConfig) String Uses

func (m *BigqueryConfig) String() string

func (*BigqueryConfig) XXX_DiscardUnknown Uses

func (m *BigqueryConfig) XXX_DiscardUnknown()

func (*BigqueryConfig) XXX_Marshal Uses

func (m *BigqueryConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BigqueryConfig) XXX_Merge Uses

func (m *BigqueryConfig) XXX_Merge(src proto.Message)

func (*BigqueryConfig) XXX_Size Uses

func (m *BigqueryConfig) XXX_Size() int

func (*BigqueryConfig) XXX_Unmarshal Uses

func (m *BigqueryConfig) XXX_Unmarshal(b []byte) error

type BuildbucketConfig Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

BuildbucketConfig contains the config to interact with Buildbucket.

func (*BuildbucketConfig) Descriptor Uses

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

func (*BuildbucketConfig) GetBucket Uses

func (m *BuildbucketConfig) GetBucket() string

func (*BuildbucketConfig) GetBuilder Uses

func (m *BuildbucketConfig) GetBuilder() string

func (*BuildbucketConfig) GetHost Uses

func (m *BuildbucketConfig) GetHost() string

func (*BuildbucketConfig) GetProject Uses

func (m *BuildbucketConfig) GetProject() string

func (*BuildbucketConfig) ProtoMessage Uses

func (*BuildbucketConfig) ProtoMessage()

func (*BuildbucketConfig) Reset Uses

func (m *BuildbucketConfig) Reset()

func (*BuildbucketConfig) String Uses

func (m *BuildbucketConfig) String() string

func (*BuildbucketConfig) XXX_DiscardUnknown Uses

func (m *BuildbucketConfig) XXX_DiscardUnknown()

func (*BuildbucketConfig) XXX_Marshal Uses

func (m *BuildbucketConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BuildbucketConfig) XXX_Merge Uses

func (m *BuildbucketConfig) XXX_Merge(src proto.Message)

func (*BuildbucketConfig) XXX_Size Uses

func (m *BuildbucketConfig) XXX_Size() int

func (*BuildbucketConfig) XXX_Unmarshal Uses

func (m *BuildbucketConfig) XXX_Unmarshal(b []byte) error

type CTPRequest Uses

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             *timestamp.Timestamp `protobuf:"bytes,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

CTPRequest defines the input of `result_flow ctp`.

func (*CTPRequest) Descriptor Uses

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

func (*CTPRequest) GetCtp Uses

func (m *CTPRequest) GetCtp() *Source

func (*CTPRequest) GetDeadline Uses

func (m *CTPRequest) GetDeadline() *timestamp.Timestamp

func (*CTPRequest) GetTestPlanRun Uses

func (m *CTPRequest) GetTestPlanRun() *Target

func (*CTPRequest) ProtoMessage Uses

func (*CTPRequest) ProtoMessage()

func (*CTPRequest) Reset Uses

func (m *CTPRequest) Reset()

func (*CTPRequest) String Uses

func (m *CTPRequest) String() string

func (*CTPRequest) XXX_DiscardUnknown Uses

func (m *CTPRequest) XXX_DiscardUnknown()

func (*CTPRequest) XXX_Marshal Uses

func (m *CTPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CTPRequest) XXX_Merge Uses

func (m *CTPRequest) XXX_Merge(src proto.Message)

func (*CTPRequest) XXX_Size Uses

func (m *CTPRequest) XXX_Size() int

func (*CTPRequest) XXX_Unmarshal Uses

func (m *CTPRequest) XXX_Unmarshal(b []byte) error

type CTPResponse Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

CTPResponse defines the output of `result_flow ctp`.

func (*CTPResponse) Descriptor Uses

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

func (*CTPResponse) GetState Uses

func (m *CTPResponse) GetState() State

func (*CTPResponse) ProtoMessage Uses

func (*CTPResponse) ProtoMessage()

func (*CTPResponse) Reset Uses

func (m *CTPResponse) Reset()

func (*CTPResponse) String Uses

func (m *CTPResponse) String() string

func (*CTPResponse) XXX_DiscardUnknown Uses

func (m *CTPResponse) XXX_DiscardUnknown()

func (*CTPResponse) XXX_Marshal Uses

func (m *CTPResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CTPResponse) XXX_Merge Uses

func (m *CTPResponse) XXX_Merge(src proto.Message)

func (*CTPResponse) XXX_Size Uses

func (m *CTPResponse) XXX_Size() int

func (*CTPResponse) XXX_Unmarshal Uses

func (m *CTPResponse) XXX_Unmarshal(b []byte) error

type PubSubConfig Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

PubSubConfig contains the config to interact with Pub/Sub.

func (*PubSubConfig) Descriptor Uses

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

func (*PubSubConfig) GetMaxReceivingMessages Uses

func (m *PubSubConfig) GetMaxReceivingMessages() int32

func (*PubSubConfig) GetProject Uses

func (m *PubSubConfig) GetProject() string

func (*PubSubConfig) GetSubscription Uses

func (m *PubSubConfig) GetSubscription() string

func (*PubSubConfig) GetTopic Uses

func (m *PubSubConfig) GetTopic() string

func (*PubSubConfig) ProtoMessage Uses

func (*PubSubConfig) ProtoMessage()

func (*PubSubConfig) Reset Uses

func (m *PubSubConfig) Reset()

func (*PubSubConfig) String Uses

func (m *PubSubConfig) String() string

func (*PubSubConfig) XXX_DiscardUnknown Uses

func (m *PubSubConfig) XXX_DiscardUnknown()

func (*PubSubConfig) XXX_Marshal Uses

func (m *PubSubConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubSubConfig) XXX_Merge Uses

func (m *PubSubConfig) XXX_Merge(src proto.Message)

func (*PubSubConfig) XXX_Size Uses

func (m *PubSubConfig) XXX_Size() int

func (*PubSubConfig) XXX_Unmarshal Uses

func (m *PubSubConfig) XXX_Unmarshal(b []byte) error

type PublishRequest Uses

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.
    ParentBuildId int64 `protobuf:"varint,2,opt,name=parent_build_id,json=parentBuildId,proto3" json:"parent_build_id,omitempty"` // Deprecated: Do not use.
    // 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 *timestamp.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 `protobuf:"varint,6,opt,name=should_poll_for_completion,json=shouldPollForCompletion,proto3" json:"should_poll_for_completion,omitempty"`
    // 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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

PublishRequest defines the input of `result_flow publish`.

func (*PublishRequest) Descriptor Uses

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

func (*PublishRequest) GetBuildId Uses

func (m *PublishRequest) GetBuildId() int64

func (*PublishRequest) GetCtp Uses

func (m *PublishRequest) GetCtp() *PubSubConfig

func (*PublishRequest) GetDeadline Uses

func (m *PublishRequest) GetDeadline() *timestamp.Timestamp

func (*PublishRequest) GetParentBuildId Uses

func (m *PublishRequest) GetParentBuildId() int64

Deprecated: Do not use.

func (*PublishRequest) GetParentUid Uses

func (m *PublishRequest) GetParentUid() string

func (*PublishRequest) GetShouldPollForCompletion Uses

func (m *PublishRequest) GetShouldPollForCompletion() bool

func (*PublishRequest) GetTestRunner Uses

func (m *PublishRequest) GetTestRunner() *PubSubConfig

func (*PublishRequest) ProtoMessage Uses

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset Uses

func (m *PublishRequest) Reset()

func (*PublishRequest) String Uses

func (m *PublishRequest) String() string

func (*PublishRequest) XXX_DiscardUnknown Uses

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal Uses

func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishRequest) XXX_Merge Uses

func (m *PublishRequest) XXX_Merge(src proto.Message)

func (*PublishRequest) XXX_Size Uses

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal Uses

func (m *PublishRequest) XXX_Unmarshal(b []byte) error

type PublishResponse Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

PublishRequest defines the output of `result_flow publish`.

func (*PublishResponse) Descriptor Uses

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

func (*PublishResponse) GetState Uses

func (m *PublishResponse) GetState() State

func (*PublishResponse) ProtoMessage Uses

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) Reset Uses

func (m *PublishResponse) Reset()

func (*PublishResponse) String Uses

func (m *PublishResponse) String() string

func (*PublishResponse) XXX_DiscardUnknown Uses

func (m *PublishResponse) XXX_DiscardUnknown()

func (*PublishResponse) XXX_Marshal Uses

func (m *PublishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishResponse) XXX_Merge Uses

func (m *PublishResponse) XXX_Merge(src proto.Message)

func (*PublishResponse) XXX_Size Uses

func (m *PublishResponse) XXX_Size() int

func (*PublishResponse) XXX_Unmarshal Uses

func (m *PublishResponse) XXX_Unmarshal(b []byte) error

type Source Uses

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"`
    XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    XXX_unrecognized     []byte             `json:"-"`
    XXX_sizecache        int32              `json:"-"`
}

Source is a wrapper for the source side configuration.

func (*Source) Descriptor Uses

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

func (*Source) GetBb Uses

func (m *Source) GetBb() *BuildbucketConfig

func (*Source) GetFields Uses

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

func (*Source) GetPubsub Uses

func (m *Source) GetPubsub() *PubSubConfig

func (*Source) ProtoMessage Uses

func (*Source) ProtoMessage()

func (*Source) Reset Uses

func (m *Source) Reset()

func (*Source) String Uses

func (m *Source) String() string

func (*Source) XXX_DiscardUnknown Uses

func (m *Source) XXX_DiscardUnknown()

func (*Source) XXX_Marshal Uses

func (m *Source) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Source) XXX_Merge Uses

func (m *Source) XXX_Merge(src proto.Message)

func (*Source) XXX_Size Uses

func (m *Source) XXX_Size() int

func (*Source) XXX_Unmarshal Uses

func (m *Source) XXX_Unmarshal(b []byte) error

type State Uses

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) EnumDescriptor Uses

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

func (State) String Uses

func (x State) String() string

type Target Uses

type Target struct {
    Bq                   *BigqueryConfig `protobuf:"bytes,1,opt,name=bq,proto3" json:"bq,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

Target is a wrapper for the target side configuration.

func (*Target) Descriptor Uses

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

func (*Target) GetBq Uses

func (m *Target) GetBq() *BigqueryConfig

func (*Target) ProtoMessage Uses

func (*Target) ProtoMessage()

func (*Target) Reset Uses

func (m *Target) Reset()

func (*Target) String Uses

func (m *Target) String() string

func (*Target) XXX_DiscardUnknown Uses

func (m *Target) XXX_DiscardUnknown()

func (*Target) XXX_Marshal Uses

func (m *Target) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Target) XXX_Merge Uses

func (m *Target) XXX_Merge(src proto.Message)

func (*Target) XXX_Size Uses

func (m *Target) XXX_Size() int

func (*Target) XXX_Unmarshal Uses

func (m *Target) XXX_Unmarshal(b []byte) error

type TestRunnerRequest Uses

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             *timestamp.Timestamp `protobuf:"bytes,4,opt,name=deadline,proto3" json:"deadline,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

TestRunnerRequest defines the input of `result_flow test_runner`.

func (*TestRunnerRequest) Descriptor Uses

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

func (*TestRunnerRequest) GetDeadline Uses

func (m *TestRunnerRequest) GetDeadline() *timestamp.Timestamp

func (*TestRunnerRequest) GetTestCase Uses

func (m *TestRunnerRequest) GetTestCase() *Target

func (*TestRunnerRequest) GetTestRun Uses

func (m *TestRunnerRequest) GetTestRun() *Target

func (*TestRunnerRequest) GetTestRunner Uses

func (m *TestRunnerRequest) GetTestRunner() *Source

func (*TestRunnerRequest) ProtoMessage Uses

func (*TestRunnerRequest) ProtoMessage()

func (*TestRunnerRequest) Reset Uses

func (m *TestRunnerRequest) Reset()

func (*TestRunnerRequest) String Uses

func (m *TestRunnerRequest) String() string

func (*TestRunnerRequest) XXX_DiscardUnknown Uses

func (m *TestRunnerRequest) XXX_DiscardUnknown()

func (*TestRunnerRequest) XXX_Marshal Uses

func (m *TestRunnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TestRunnerRequest) XXX_Merge Uses

func (m *TestRunnerRequest) XXX_Merge(src proto.Message)

func (*TestRunnerRequest) XXX_Size Uses

func (m *TestRunnerRequest) XXX_Size() int

func (*TestRunnerRequest) XXX_Unmarshal Uses

func (m *TestRunnerRequest) XXX_Unmarshal(b []byte) error

type TestRunnerResponse Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

TestRunnerResponse defines the output of `result_flow test_runner`.

func (*TestRunnerResponse) Descriptor Uses

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

func (*TestRunnerResponse) GetState Uses

func (m *TestRunnerResponse) GetState() State

func (*TestRunnerResponse) ProtoMessage Uses

func (*TestRunnerResponse) ProtoMessage()

func (*TestRunnerResponse) Reset Uses

func (m *TestRunnerResponse) Reset()

func (*TestRunnerResponse) String Uses

func (m *TestRunnerResponse) String() string

func (*TestRunnerResponse) XXX_DiscardUnknown Uses

func (m *TestRunnerResponse) XXX_DiscardUnknown()

func (*TestRunnerResponse) XXX_Marshal Uses

func (m *TestRunnerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TestRunnerResponse) XXX_Merge Uses

func (m *TestRunnerResponse) XXX_Merge(src proto.Message)

func (*TestRunnerResponse) XXX_Size Uses

func (m *TestRunnerResponse) XXX_Size() int

func (*TestRunnerResponse) XXX_Unmarshal Uses

func (m *TestRunnerResponse) XXX_Unmarshal(b []byte) error

Package result_flow imports 4 packages (graph). Updated 2020-10-26. Refresh now. Tools for package owners.