blob: 623a3b47098a0b6385e6d27fcdf144e5cf282e5e [file] [log] [blame]
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: test_platform/multibot/requests.proto
package test_platform_multibot
import (
fmt "fmt"
proto ""
test_platform ""
phosphorus ""
math "math"
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
// External API for requesting a multi-bot job
type LeaderRequest struct {
// What test to run with the multi-bot task
Payload *test_platform.Request_Test `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
// What attributes to require and provision for follower tasks
FollowerSpecs []*FollowerSpec `protobuf:"bytes,2,rep,name=follower_specs,json=followerSpecs,proto3" json:"follower_specs,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
func (m *LeaderRequest) Reset() { *m = LeaderRequest{} }
func (m *LeaderRequest) String() string { return proto.CompactTextString(m) }
func (*LeaderRequest) ProtoMessage() {}
func (*LeaderRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_912b836f52cd13db, []int{0}
func (m *LeaderRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_LeaderRequest.Unmarshal(m, b)
func (m *LeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_LeaderRequest.Marshal(b, m, deterministic)
func (m *LeaderRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_LeaderRequest.Merge(m, src)
func (m *LeaderRequest) XXX_Size() int {
return xxx_messageInfo_LeaderRequest.Size(m)
func (m *LeaderRequest) XXX_DiscardUnknown() {
var xxx_messageInfo_LeaderRequest proto.InternalMessageInfo
func (m *LeaderRequest) GetPayload() *test_platform.Request_Test {
if m != nil {
return m.Payload
return nil
func (m *LeaderRequest) GetFollowerSpecs() []*FollowerSpec {
if m != nil {
return m.FollowerSpecs
return nil
// Internal per-bot request for follower task
type FollowerRequest struct {
// Pubsub subscription to use for this follower task (pre-existing)
SubscriptionName string `protobuf:"bytes,1,opt,name=subscription_name,json=subscriptionName,proto3" json:"subscription_name,omitempty"`
// Attribute filter to apply to judge whether incoming messages are 'for you'
IncomingFilter map[string]string `protobuf:"bytes,2,rep,name=incoming_filter,json=incomingFilter,proto3" json:"incoming_filter,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Attributes to apply to outgoing messages to address them to the leader
OutgoingAttributes map[string]string `protobuf:"bytes,3,rep,name=outgoing_attributes,json=outgoingAttributes,proto3" json:"outgoing_attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Prejob request parameters
Prejob *phosphorus.PrejobRequest `protobuf:"bytes,4,opt,name=prejob,proto3" json:"prejob,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
func (m *FollowerRequest) Reset() { *m = FollowerRequest{} }
func (m *FollowerRequest) String() string { return proto.CompactTextString(m) }
func (*FollowerRequest) ProtoMessage() {}
func (*FollowerRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_912b836f52cd13db, []int{1}
func (m *FollowerRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FollowerRequest.Unmarshal(m, b)
func (m *FollowerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FollowerRequest.Marshal(b, m, deterministic)
func (m *FollowerRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_FollowerRequest.Merge(m, src)
func (m *FollowerRequest) XXX_Size() int {
return xxx_messageInfo_FollowerRequest.Size(m)
func (m *FollowerRequest) XXX_DiscardUnknown() {
var xxx_messageInfo_FollowerRequest proto.InternalMessageInfo
func (m *FollowerRequest) GetSubscriptionName() string {
if m != nil {
return m.SubscriptionName
return ""
func (m *FollowerRequest) GetIncomingFilter() map[string]string {
if m != nil {
return m.IncomingFilter
return nil
func (m *FollowerRequest) GetOutgoingAttributes() map[string]string {
if m != nil {
return m.OutgoingAttributes
return nil
func (m *FollowerRequest) GetPrejob() *phosphorus.PrejobRequest {
if m != nil {
return m.Prejob
return nil
func init() {
proto.RegisterType((*LeaderRequest)(nil), "test_platform.multibot.LeaderRequest")
proto.RegisterType((*FollowerRequest)(nil), "test_platform.multibot.FollowerRequest")
proto.RegisterMapType((map[string]string)(nil), "test_platform.multibot.FollowerRequest.IncomingFilterEntry")
proto.RegisterMapType((map[string]string)(nil), "test_platform.multibot.FollowerRequest.OutgoingAttributesEntry")
func init() {
proto.RegisterFile("test_platform/multibot/requests.proto", fileDescriptor_912b836f52cd13db)
var fileDescriptor_912b836f52cd13db = []byte{
// 386 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x52, 0x5d, 0x8b, 0xd3, 0x40,
0x14, 0x25, 0x8d, 0x56, 0x9c, 0xd2, 0x0f, 0xa7, 0xa2, 0x21, 0x7d, 0x29, 0x55, 0xb1, 0x20, 0xa4,
0x50, 0x11, 0x44, 0x1f, 0x4a, 0x1f, 0x5a, 0x10, 0x45, 0x25, 0xfa, 0x1e, 0x26, 0xe9, 0x4d, 0x3b,
0x9a, 0xe4, 0xce, 0xce, 0x4c, 0x76, 0xe9, 0xef, 0xd8, 0x5f, 0xb8, 0xff, 0x64, 0x69, 0x32, 0xd9,
0x6d, 0xba, 0x2d, 0xbb, 0xfb, 0x96, 0x7b, 0xcf, 0x39, 0xf7, 0x9c, 0x9b, 0xb9, 0xe4, 0x9d, 0x06,
0xa5, 0x03, 0x91, 0x30, 0x1d, 0xa3, 0x4c, 0x27, 0x69, 0x9e, 0x68, 0x1e, 0xa2, 0x9e, 0x48, 0x38,
0xcb, 0x41, 0x69, 0xe5, 0x09, 0x89, 0x1a, 0xe9, 0xab, 0x1a, 0xcd, 0xab, 0x68, 0xee, 0x81, 0x5c,
0x6c, 0x50, 0x89, 0x0d, 0xca, 0x5c, 0x4d, 0x84, 0x84, 0x7f, 0x18, 0x96, 0x72, 0xf7, 0xcd, 0x09,
0x97, 0x08, 0xd3, 0x14, 0x33, 0x43, 0x1a, 0xd4, 0x49, 0x26, 0x41, 0x09, 0x8e, 0x2e, 0x2d, 0xd2,
0xfe, 0x01, 0x6c, 0x05, 0xd2, 0x2f, 0xfb, 0xf4, 0x13, 0x79, 0x26, 0xd8, 0x36, 0x41, 0xb6, 0x72,
0xac, 0xa1, 0x35, 0x6e, 0x4d, 0x07, 0x5e, 0x3d, 0xa4, 0x21, 0x7a, 0x7f, 0x41, 0x69, 0xbf, 0xe2,
0xd2, 0xef, 0xa4, 0x13, 0x63, 0x92, 0xe0, 0x05, 0xc8, 0x40, 0x09, 0x88, 0x94, 0xd3, 0x18, 0xda,
0xe3, 0xd6, 0xf4, 0xad, 0x77, 0x7c, 0x45, 0x6f, 0x69, 0xd8, 0x7f, 0x04, 0x44, 0x7e, 0x3b, 0xde,
0xab, 0xd4, 0xe8, 0xca, 0x26, 0xdd, 0x0a, 0xaf, 0x72, 0x7d, 0x20, 0x2f, 0x54, 0x1e, 0xaa, 0x48,
0x72, 0xa1, 0x39, 0x66, 0x41, 0xc6, 0x52, 0x28, 0x12, 0x3e, 0xf7, 0x7b, 0xfb, 0xc0, 0x4f, 0x96,
0x02, 0x5d, 0x91, 0x2e, 0xcf, 0x22, 0x4c, 0x79, 0xb6, 0x0e, 0x62, 0x9e, 0x68, 0x90, 0x26, 0xce,
0xd7, 0xfb, 0xe2, 0x54, 0xdb, 0x7d, 0x33, 0xf2, 0x65, 0xa1, 0x5e, 0x64, 0x5a, 0x6e, 0xfd, 0x0e,
0xaf, 0x35, 0xa9, 0x20, 0x7d, 0xcc, 0xf5, 0x1a, 0x77, 0x2e, 0x4c, 0x6b, 0xc9, 0xc3, 0x5c, 0x83,
0x72, 0xec, 0xc2, 0x69, 0xf6, 0x50, 0xa7, 0x5f, 0x66, 0xc4, 0xfc, 0x66, 0x42, 0xe9, 0x46, 0xf1,
0x0e, 0x40, 0x67, 0xa4, 0x59, 0x1e, 0x80, 0xf3, 0xa4, 0x78, 0x9b, 0xf7, 0x07, 0x26, 0xb7, 0x87,
0xe2, 0xfd, 0x2e, 0x78, 0xc6, 0xc4, 0x37, 0x32, 0x77, 0x4e, 0xfa, 0x47, 0x36, 0xa3, 0x3d, 0x62,
0xff, 0x87, 0xad, 0xf9, 0x9d, 0xbb, 0x4f, 0xfa, 0x92, 0x3c, 0x3d, 0x67, 0x49, 0x0e, 0x4e, 0xa3,
0xe8, 0x95, 0xc5, 0x97, 0xc6, 0x67, 0xcb, 0x5d, 0x90, 0xd7, 0x27, 0x22, 0x3f, 0x66, 0x4c, 0xd8,
0x2c, 0x0e, 0xf0, 0xe3, 0x75, 0x00, 0x00, 0x00, 0xff, 0xff, 0x33, 0x45, 0x2a, 0xec, 0x2a, 0x03,
0x00, 0x00,