// Code generated by protoc-gen-gogo. DO NOT EDIT. // source: controller.proto package pb import ( context "context" fmt "fmt" proto "github.com/gogo/protobuf/proto" control "github.com/moby/buildkit/api/services/control" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" 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.GoGoProtoPackageIsVersion3 // please upgrade the proto package type BuildRequest struct { Ref string `protobuf:"bytes,1,opt,name=Ref,proto3" json:"Ref,omitempty"` Options *BuildOptions `protobuf:"bytes,2,opt,name=Options,proto3" json:"Options,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *BuildRequest) Reset() { *m = BuildRequest{} } func (m *BuildRequest) String() string { return proto.CompactTextString(m) } func (*BuildRequest) ProtoMessage() {} func (*BuildRequest) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{0} } func (m *BuildRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_BuildRequest.Unmarshal(m, b) } func (m *BuildRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_BuildRequest.Marshal(b, m, deterministic) } func (m *BuildRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_BuildRequest.Merge(m, src) } func (m *BuildRequest) XXX_Size() int { return xxx_messageInfo_BuildRequest.Size(m) } func (m *BuildRequest) XXX_DiscardUnknown() { xxx_messageInfo_BuildRequest.DiscardUnknown(m) } var xxx_messageInfo_BuildRequest proto.InternalMessageInfo func (m *BuildRequest) GetRef() string { if m != nil { return m.Ref } return "" } func (m *BuildRequest) GetOptions() *BuildOptions { if m != nil { return m.Options } return nil } type BuildOptions struct { ContextPath string `protobuf:"bytes,1,opt,name=ContextPath,proto3" json:"ContextPath,omitempty"` DockerfileName string `protobuf:"bytes,2,opt,name=DockerfileName,proto3" json:"DockerfileName,omitempty"` PrintFunc string `protobuf:"bytes,3,opt,name=PrintFunc,proto3" json:"PrintFunc,omitempty"` Allow []string `protobuf:"bytes,4,rep,name=Allow,proto3" json:"Allow,omitempty"` Attests []string `protobuf:"bytes,5,rep,name=Attests,proto3" json:"Attests,omitempty"` BuildArgs []string `protobuf:"bytes,6,rep,name=BuildArgs,proto3" json:"BuildArgs,omitempty"` CacheFrom []string `protobuf:"bytes,7,rep,name=CacheFrom,proto3" json:"CacheFrom,omitempty"` CacheTo []string `protobuf:"bytes,8,rep,name=CacheTo,proto3" json:"CacheTo,omitempty"` CgroupParent string `protobuf:"bytes,9,opt,name=CgroupParent,proto3" json:"CgroupParent,omitempty"` Contexts []string `protobuf:"bytes,10,rep,name=Contexts,proto3" json:"Contexts,omitempty"` ExtraHosts []string `protobuf:"bytes,11,rep,name=ExtraHosts,proto3" json:"ExtraHosts,omitempty"` ImageIDFile string `protobuf:"bytes,12,opt,name=ImageIDFile,proto3" json:"ImageIDFile,omitempty"` Labels []string `protobuf:"bytes,13,rep,name=Labels,proto3" json:"Labels,omitempty"` NetworkMode string `protobuf:"bytes,14,opt,name=NetworkMode,proto3" json:"NetworkMode,omitempty"` NoCacheFilter []string `protobuf:"bytes,15,rep,name=NoCacheFilter,proto3" json:"NoCacheFilter,omitempty"` Outputs []string `protobuf:"bytes,16,rep,name=Outputs,proto3" json:"Outputs,omitempty"` Platforms []string `protobuf:"bytes,17,rep,name=Platforms,proto3" json:"Platforms,omitempty"` Quiet bool `protobuf:"varint,18,opt,name=Quiet,proto3" json:"Quiet,omitempty"` Secrets []string `protobuf:"bytes,19,rep,name=Secrets,proto3" json:"Secrets,omitempty"` ShmSize int64 `protobuf:"varint,20,opt,name=ShmSize,proto3" json:"ShmSize,omitempty"` SSH []string `protobuf:"bytes,21,rep,name=SSH,proto3" json:"SSH,omitempty"` Tags []string `protobuf:"bytes,22,rep,name=Tags,proto3" json:"Tags,omitempty"` Target string `protobuf:"bytes,23,opt,name=Target,proto3" json:"Target,omitempty"` Ulimits *UlimitOpt `protobuf:"bytes,24,opt,name=Ulimits,proto3" json:"Ulimits,omitempty"` // string Invoke: provided via Invoke API Opts *CommonOptions `protobuf:"bytes,25,opt,name=Opts,proto3" json:"Opts,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *BuildOptions) Reset() { *m = BuildOptions{} } func (m *BuildOptions) String() string { return proto.CompactTextString(m) } func (*BuildOptions) ProtoMessage() {} func (*BuildOptions) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{1} } func (m *BuildOptions) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_BuildOptions.Unmarshal(m, b) } func (m *BuildOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_BuildOptions.Marshal(b, m, deterministic) } func (m *BuildOptions) XXX_Merge(src proto.Message) { xxx_messageInfo_BuildOptions.Merge(m, src) } func (m *BuildOptions) XXX_Size() int { return xxx_messageInfo_BuildOptions.Size(m) } func (m *BuildOptions) XXX_DiscardUnknown() { xxx_messageInfo_BuildOptions.DiscardUnknown(m) } var xxx_messageInfo_BuildOptions proto.InternalMessageInfo func (m *BuildOptions) GetContextPath() string { if m != nil { return m.ContextPath } return "" } func (m *BuildOptions) GetDockerfileName() string { if m != nil { return m.DockerfileName } return "" } func (m *BuildOptions) GetPrintFunc() string { if m != nil { return m.PrintFunc } return "" } func (m *BuildOptions) GetAllow() []string { if m != nil { return m.Allow } return nil } func (m *BuildOptions) GetAttests() []string { if m != nil { return m.Attests } return nil } func (m *BuildOptions) GetBuildArgs() []string { if m != nil { return m.BuildArgs } return nil } func (m *BuildOptions) GetCacheFrom() []string { if m != nil { return m.CacheFrom } return nil } func (m *BuildOptions) GetCacheTo() []string { if m != nil { return m.CacheTo } return nil } func (m *BuildOptions) GetCgroupParent() string { if m != nil { return m.CgroupParent } return "" } func (m *BuildOptions) GetContexts() []string { if m != nil { return m.Contexts } return nil } func (m *BuildOptions) GetExtraHosts() []string { if m != nil { return m.ExtraHosts } return nil } func (m *BuildOptions) GetImageIDFile() string { if m != nil { return m.ImageIDFile } return "" } func (m *BuildOptions) GetLabels() []string { if m != nil { return m.Labels } return nil } func (m *BuildOptions) GetNetworkMode() string { if m != nil { return m.NetworkMode } return "" } func (m *BuildOptions) GetNoCacheFilter() []string { if m != nil { return m.NoCacheFilter } return nil } func (m *BuildOptions) GetOutputs() []string { if m != nil { return m.Outputs } return nil } func (m *BuildOptions) GetPlatforms() []string { if m != nil { return m.Platforms } return nil } func (m *BuildOptions) GetQuiet() bool { if m != nil { return m.Quiet } return false } func (m *BuildOptions) GetSecrets() []string { if m != nil { return m.Secrets } return nil } func (m *BuildOptions) GetShmSize() int64 { if m != nil { return m.ShmSize } return 0 } func (m *BuildOptions) GetSSH() []string { if m != nil { return m.SSH } return nil } func (m *BuildOptions) GetTags() []string { if m != nil { return m.Tags } return nil } func (m *BuildOptions) GetTarget() string { if m != nil { return m.Target } return "" } func (m *BuildOptions) GetUlimits() *UlimitOpt { if m != nil { return m.Ulimits } return nil } func (m *BuildOptions) GetOpts() *CommonOptions { if m != nil { return m.Opts } return nil } type UlimitOpt struct { Values map[string]*Ulimit `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *UlimitOpt) Reset() { *m = UlimitOpt{} } func (m *UlimitOpt) String() string { return proto.CompactTextString(m) } func (*UlimitOpt) ProtoMessage() {} func (*UlimitOpt) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{2} } func (m *UlimitOpt) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_UlimitOpt.Unmarshal(m, b) } func (m *UlimitOpt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_UlimitOpt.Marshal(b, m, deterministic) } func (m *UlimitOpt) XXX_Merge(src proto.Message) { xxx_messageInfo_UlimitOpt.Merge(m, src) } func (m *UlimitOpt) XXX_Size() int { return xxx_messageInfo_UlimitOpt.Size(m) } func (m *UlimitOpt) XXX_DiscardUnknown() { xxx_messageInfo_UlimitOpt.DiscardUnknown(m) } var xxx_messageInfo_UlimitOpt proto.InternalMessageInfo func (m *UlimitOpt) GetValues() map[string]*Ulimit { if m != nil { return m.Values } return nil } type Ulimit struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Hard int64 `protobuf:"varint,2,opt,name=Hard,proto3" json:"Hard,omitempty"` Soft int64 `protobuf:"varint,3,opt,name=Soft,proto3" json:"Soft,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *Ulimit) Reset() { *m = Ulimit{} } func (m *Ulimit) String() string { return proto.CompactTextString(m) } func (*Ulimit) ProtoMessage() {} func (*Ulimit) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{3} } func (m *Ulimit) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Ulimit.Unmarshal(m, b) } func (m *Ulimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Ulimit.Marshal(b, m, deterministic) } func (m *Ulimit) XXX_Merge(src proto.Message) { xxx_messageInfo_Ulimit.Merge(m, src) } func (m *Ulimit) XXX_Size() int { return xxx_messageInfo_Ulimit.Size(m) } func (m *Ulimit) XXX_DiscardUnknown() { xxx_messageInfo_Ulimit.DiscardUnknown(m) } var xxx_messageInfo_Ulimit proto.InternalMessageInfo func (m *Ulimit) GetName() string { if m != nil { return m.Name } return "" } func (m *Ulimit) GetHard() int64 { if m != nil { return m.Hard } return 0 } func (m *Ulimit) GetSoft() int64 { if m != nil { return m.Soft } return 0 } type CommonOptions struct { Builder string `protobuf:"bytes,1,opt,name=Builder,proto3" json:"Builder,omitempty"` MetadataFile string `protobuf:"bytes,2,opt,name=MetadataFile,proto3" json:"MetadataFile,omitempty"` NoCache bool `protobuf:"varint,3,opt,name=NoCache,proto3" json:"NoCache,omitempty"` // string Progress: no progress view on server side Pull bool `protobuf:"varint,4,opt,name=Pull,proto3" json:"Pull,omitempty"` ExportPush bool `protobuf:"varint,5,opt,name=ExportPush,proto3" json:"ExportPush,omitempty"` ExportLoad bool `protobuf:"varint,6,opt,name=ExportLoad,proto3" json:"ExportLoad,omitempty"` SBOM string `protobuf:"bytes,7,opt,name=SBOM,proto3" json:"SBOM,omitempty"` Provenance string `protobuf:"bytes,8,opt,name=Provenance,proto3" json:"Provenance,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *CommonOptions) Reset() { *m = CommonOptions{} } func (m *CommonOptions) String() string { return proto.CompactTextString(m) } func (*CommonOptions) ProtoMessage() {} func (*CommonOptions) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{4} } func (m *CommonOptions) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_CommonOptions.Unmarshal(m, b) } func (m *CommonOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_CommonOptions.Marshal(b, m, deterministic) } func (m *CommonOptions) XXX_Merge(src proto.Message) { xxx_messageInfo_CommonOptions.Merge(m, src) } func (m *CommonOptions) XXX_Size() int { return xxx_messageInfo_CommonOptions.Size(m) } func (m *CommonOptions) XXX_DiscardUnknown() { xxx_messageInfo_CommonOptions.DiscardUnknown(m) } var xxx_messageInfo_CommonOptions proto.InternalMessageInfo func (m *CommonOptions) GetBuilder() string { if m != nil { return m.Builder } return "" } func (m *CommonOptions) GetMetadataFile() string { if m != nil { return m.MetadataFile } return "" } func (m *CommonOptions) GetNoCache() bool { if m != nil { return m.NoCache } return false } func (m *CommonOptions) GetPull() bool { if m != nil { return m.Pull } return false } func (m *CommonOptions) GetExportPush() bool { if m != nil { return m.ExportPush } return false } func (m *CommonOptions) GetExportLoad() bool { if m != nil { return m.ExportLoad } return false } func (m *CommonOptions) GetSBOM() string { if m != nil { return m.SBOM } return "" } func (m *CommonOptions) GetProvenance() string { if m != nil { return m.Provenance } return "" } type BuildResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *BuildResponse) Reset() { *m = BuildResponse{} } func (m *BuildResponse) String() string { return proto.CompactTextString(m) } func (*BuildResponse) ProtoMessage() {} func (*BuildResponse) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{5} } func (m *BuildResponse) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_BuildResponse.Unmarshal(m, b) } func (m *BuildResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_BuildResponse.Marshal(b, m, deterministic) } func (m *BuildResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_BuildResponse.Merge(m, src) } func (m *BuildResponse) XXX_Size() int { return xxx_messageInfo_BuildResponse.Size(m) } func (m *BuildResponse) XXX_DiscardUnknown() { xxx_messageInfo_BuildResponse.DiscardUnknown(m) } var xxx_messageInfo_BuildResponse proto.InternalMessageInfo type DisconnectRequest struct { Ref string `protobuf:"bytes,1,opt,name=Ref,proto3" json:"Ref,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *DisconnectRequest) Reset() { *m = DisconnectRequest{} } func (m *DisconnectRequest) String() string { return proto.CompactTextString(m) } func (*DisconnectRequest) ProtoMessage() {} func (*DisconnectRequest) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{6} } func (m *DisconnectRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_DisconnectRequest.Unmarshal(m, b) } func (m *DisconnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_DisconnectRequest.Marshal(b, m, deterministic) } func (m *DisconnectRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_DisconnectRequest.Merge(m, src) } func (m *DisconnectRequest) XXX_Size() int { return xxx_messageInfo_DisconnectRequest.Size(m) } func (m *DisconnectRequest) XXX_DiscardUnknown() { xxx_messageInfo_DisconnectRequest.DiscardUnknown(m) } var xxx_messageInfo_DisconnectRequest proto.InternalMessageInfo func (m *DisconnectRequest) GetRef() string { if m != nil { return m.Ref } return "" } type DisconnectResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *DisconnectResponse) Reset() { *m = DisconnectResponse{} } func (m *DisconnectResponse) String() string { return proto.CompactTextString(m) } func (*DisconnectResponse) ProtoMessage() {} func (*DisconnectResponse) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{7} } func (m *DisconnectResponse) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_DisconnectResponse.Unmarshal(m, b) } func (m *DisconnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_DisconnectResponse.Marshal(b, m, deterministic) } func (m *DisconnectResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_DisconnectResponse.Merge(m, src) } func (m *DisconnectResponse) XXX_Size() int { return xxx_messageInfo_DisconnectResponse.Size(m) } func (m *DisconnectResponse) XXX_DiscardUnknown() { xxx_messageInfo_DisconnectResponse.DiscardUnknown(m) } var xxx_messageInfo_DisconnectResponse proto.InternalMessageInfo type ListRequest struct { Ref string `protobuf:"bytes,1,opt,name=Ref,proto3" json:"Ref,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ListRequest) Reset() { *m = ListRequest{} } func (m *ListRequest) String() string { return proto.CompactTextString(m) } func (*ListRequest) ProtoMessage() {} func (*ListRequest) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{8} } func (m *ListRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ListRequest.Unmarshal(m, b) } func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ListRequest.Marshal(b, m, deterministic) } func (m *ListRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_ListRequest.Merge(m, src) } func (m *ListRequest) XXX_Size() int { return xxx_messageInfo_ListRequest.Size(m) } func (m *ListRequest) XXX_DiscardUnknown() { xxx_messageInfo_ListRequest.DiscardUnknown(m) } var xxx_messageInfo_ListRequest proto.InternalMessageInfo func (m *ListRequest) GetRef() string { if m != nil { return m.Ref } return "" } type ListResponse struct { Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ListResponse) Reset() { *m = ListResponse{} } func (m *ListResponse) String() string { return proto.CompactTextString(m) } func (*ListResponse) ProtoMessage() {} func (*ListResponse) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{9} } func (m *ListResponse) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ListResponse.Unmarshal(m, b) } func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ListResponse.Marshal(b, m, deterministic) } func (m *ListResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_ListResponse.Merge(m, src) } func (m *ListResponse) XXX_Size() int { return xxx_messageInfo_ListResponse.Size(m) } func (m *ListResponse) XXX_DiscardUnknown() { xxx_messageInfo_ListResponse.DiscardUnknown(m) } var xxx_messageInfo_ListResponse proto.InternalMessageInfo func (m *ListResponse) GetKeys() []string { if m != nil { return m.Keys } return nil } type InputMessage struct { // Types that are valid to be assigned to Input: // *InputMessage_Init // *InputMessage_Data Input isInputMessage_Input `protobuf_oneof:"Input"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *InputMessage) Reset() { *m = InputMessage{} } func (m *InputMessage) String() string { return proto.CompactTextString(m) } func (*InputMessage) ProtoMessage() {} func (*InputMessage) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{10} } func (m *InputMessage) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_InputMessage.Unmarshal(m, b) } func (m *InputMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_InputMessage.Marshal(b, m, deterministic) } func (m *InputMessage) XXX_Merge(src proto.Message) { xxx_messageInfo_InputMessage.Merge(m, src) } func (m *InputMessage) XXX_Size() int { return xxx_messageInfo_InputMessage.Size(m) } func (m *InputMessage) XXX_DiscardUnknown() { xxx_messageInfo_InputMessage.DiscardUnknown(m) } var xxx_messageInfo_InputMessage proto.InternalMessageInfo type isInputMessage_Input interface { isInputMessage_Input() } type InputMessage_Init struct { Init *InputInitMessage `protobuf:"bytes,1,opt,name=Init,proto3,oneof" json:"Init,omitempty"` } type InputMessage_Data struct { Data *DataMessage `protobuf:"bytes,2,opt,name=Data,proto3,oneof" json:"Data,omitempty"` } func (*InputMessage_Init) isInputMessage_Input() {} func (*InputMessage_Data) isInputMessage_Input() {} func (m *InputMessage) GetInput() isInputMessage_Input { if m != nil { return m.Input } return nil } func (m *InputMessage) GetInit() *InputInitMessage { if x, ok := m.GetInput().(*InputMessage_Init); ok { return x.Init } return nil } func (m *InputMessage) GetData() *DataMessage { if x, ok := m.GetInput().(*InputMessage_Data); ok { return x.Data } return nil } // XXX_OneofWrappers is for the internal use of the proto package. func (*InputMessage) XXX_OneofWrappers() []interface{} { return []interface{}{ (*InputMessage_Init)(nil), (*InputMessage_Data)(nil), } } type InputInitMessage struct { Ref string `protobuf:"bytes,1,opt,name=Ref,proto3" json:"Ref,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *InputInitMessage) Reset() { *m = InputInitMessage{} } func (m *InputInitMessage) String() string { return proto.CompactTextString(m) } func (*InputInitMessage) ProtoMessage() {} func (*InputInitMessage) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{11} } func (m *InputInitMessage) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_InputInitMessage.Unmarshal(m, b) } func (m *InputInitMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_InputInitMessage.Marshal(b, m, deterministic) } func (m *InputInitMessage) XXX_Merge(src proto.Message) { xxx_messageInfo_InputInitMessage.Merge(m, src) } func (m *InputInitMessage) XXX_Size() int { return xxx_messageInfo_InputInitMessage.Size(m) } func (m *InputInitMessage) XXX_DiscardUnknown() { xxx_messageInfo_InputInitMessage.DiscardUnknown(m) } var xxx_messageInfo_InputInitMessage proto.InternalMessageInfo func (m *InputInitMessage) GetRef() string { if m != nil { return m.Ref } return "" } type DataMessage struct { EOF bool `protobuf:"varint,1,opt,name=EOF,proto3" json:"EOF,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *DataMessage) Reset() { *m = DataMessage{} } func (m *DataMessage) String() string { return proto.CompactTextString(m) } func (*DataMessage) ProtoMessage() {} func (*DataMessage) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{12} } func (m *DataMessage) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_DataMessage.Unmarshal(m, b) } func (m *DataMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_DataMessage.Marshal(b, m, deterministic) } func (m *DataMessage) XXX_Merge(src proto.Message) { xxx_messageInfo_DataMessage.Merge(m, src) } func (m *DataMessage) XXX_Size() int { return xxx_messageInfo_DataMessage.Size(m) } func (m *DataMessage) XXX_DiscardUnknown() { xxx_messageInfo_DataMessage.DiscardUnknown(m) } var xxx_messageInfo_DataMessage proto.InternalMessageInfo func (m *DataMessage) GetEOF() bool { if m != nil { return m.EOF } return false } func (m *DataMessage) GetData() []byte { if m != nil { return m.Data } return nil } type InputResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *InputResponse) Reset() { *m = InputResponse{} } func (m *InputResponse) String() string { return proto.CompactTextString(m) } func (*InputResponse) ProtoMessage() {} func (*InputResponse) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{13} } func (m *InputResponse) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_InputResponse.Unmarshal(m, b) } func (m *InputResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_InputResponse.Marshal(b, m, deterministic) } func (m *InputResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_InputResponse.Merge(m, src) } func (m *InputResponse) XXX_Size() int { return xxx_messageInfo_InputResponse.Size(m) } func (m *InputResponse) XXX_DiscardUnknown() { xxx_messageInfo_InputResponse.DiscardUnknown(m) } var xxx_messageInfo_InputResponse proto.InternalMessageInfo type Message struct { // Types that are valid to be assigned to Input: // *Message_Init // *Message_File // *Message_Resize // *Message_Signal Input isMessage_Input `protobuf_oneof:"Input"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *Message) Reset() { *m = Message{} } func (m *Message) String() string { return proto.CompactTextString(m) } func (*Message) ProtoMessage() {} func (*Message) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{14} } func (m *Message) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Message.Unmarshal(m, b) } func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Message.Marshal(b, m, deterministic) } func (m *Message) XXX_Merge(src proto.Message) { xxx_messageInfo_Message.Merge(m, src) } func (m *Message) XXX_Size() int { return xxx_messageInfo_Message.Size(m) } func (m *Message) XXX_DiscardUnknown() { xxx_messageInfo_Message.DiscardUnknown(m) } var xxx_messageInfo_Message proto.InternalMessageInfo type isMessage_Input interface { isMessage_Input() } type Message_Init struct { Init *InitMessage `protobuf:"bytes,1,opt,name=Init,proto3,oneof" json:"Init,omitempty"` } type Message_File struct { File *FdMessage `protobuf:"bytes,2,opt,name=File,proto3,oneof" json:"File,omitempty"` } type Message_Resize struct { Resize *ResizeMessage `protobuf:"bytes,3,opt,name=Resize,proto3,oneof" json:"Resize,omitempty"` } type Message_Signal struct { Signal *SignalMessage `protobuf:"bytes,4,opt,name=Signal,proto3,oneof" json:"Signal,omitempty"` } func (*Message_Init) isMessage_Input() {} func (*Message_File) isMessage_Input() {} func (*Message_Resize) isMessage_Input() {} func (*Message_Signal) isMessage_Input() {} func (m *Message) GetInput() isMessage_Input { if m != nil { return m.Input } return nil } func (m *Message) GetInit() *InitMessage { if x, ok := m.GetInput().(*Message_Init); ok { return x.Init } return nil } func (m *Message) GetFile() *FdMessage { if x, ok := m.GetInput().(*Message_File); ok { return x.File } return nil } func (m *Message) GetResize() *ResizeMessage { if x, ok := m.GetInput().(*Message_Resize); ok { return x.Resize } return nil } func (m *Message) GetSignal() *SignalMessage { if x, ok := m.GetInput().(*Message_Signal); ok { return x.Signal } return nil } // XXX_OneofWrappers is for the internal use of the proto package. func (*Message) XXX_OneofWrappers() []interface{} { return []interface{}{ (*Message_Init)(nil), (*Message_File)(nil), (*Message_Resize)(nil), (*Message_Signal)(nil), } } type InitMessage struct { Ref string `protobuf:"bytes,1,opt,name=Ref,proto3" json:"Ref,omitempty"` ContainerConfig *ContainerConfig `protobuf:"bytes,2,opt,name=ContainerConfig,proto3" json:"ContainerConfig,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *InitMessage) Reset() { *m = InitMessage{} } func (m *InitMessage) String() string { return proto.CompactTextString(m) } func (*InitMessage) ProtoMessage() {} func (*InitMessage) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{15} } func (m *InitMessage) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_InitMessage.Unmarshal(m, b) } func (m *InitMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_InitMessage.Marshal(b, m, deterministic) } func (m *InitMessage) XXX_Merge(src proto.Message) { xxx_messageInfo_InitMessage.Merge(m, src) } func (m *InitMessage) XXX_Size() int { return xxx_messageInfo_InitMessage.Size(m) } func (m *InitMessage) XXX_DiscardUnknown() { xxx_messageInfo_InitMessage.DiscardUnknown(m) } var xxx_messageInfo_InitMessage proto.InternalMessageInfo func (m *InitMessage) GetRef() string { if m != nil { return m.Ref } return "" } func (m *InitMessage) GetContainerConfig() *ContainerConfig { if m != nil { return m.ContainerConfig } return nil } type ContainerConfig struct { Entrypoint []string `protobuf:"bytes,1,rep,name=Entrypoint,proto3" json:"Entrypoint,omitempty"` Cmd []string `protobuf:"bytes,2,rep,name=Cmd,proto3" json:"Cmd,omitempty"` Env []string `protobuf:"bytes,3,rep,name=Env,proto3" json:"Env,omitempty"` User string `protobuf:"bytes,4,opt,name=User,proto3" json:"User,omitempty"` NoUser bool `protobuf:"varint,5,opt,name=NoUser,proto3" json:"NoUser,omitempty"` Cwd string `protobuf:"bytes,6,opt,name=Cwd,proto3" json:"Cwd,omitempty"` NoCwd bool `protobuf:"varint,7,opt,name=NoCwd,proto3" json:"NoCwd,omitempty"` Tty bool `protobuf:"varint,8,opt,name=Tty,proto3" json:"Tty,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ContainerConfig) Reset() { *m = ContainerConfig{} } func (m *ContainerConfig) String() string { return proto.CompactTextString(m) } func (*ContainerConfig) ProtoMessage() {} func (*ContainerConfig) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{16} } func (m *ContainerConfig) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ContainerConfig.Unmarshal(m, b) } func (m *ContainerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ContainerConfig.Marshal(b, m, deterministic) } func (m *ContainerConfig) XXX_Merge(src proto.Message) { xxx_messageInfo_ContainerConfig.Merge(m, src) } func (m *ContainerConfig) XXX_Size() int { return xxx_messageInfo_ContainerConfig.Size(m) } func (m *ContainerConfig) XXX_DiscardUnknown() { xxx_messageInfo_ContainerConfig.DiscardUnknown(m) } var xxx_messageInfo_ContainerConfig proto.InternalMessageInfo func (m *ContainerConfig) GetEntrypoint() []string { if m != nil { return m.Entrypoint } return nil } func (m *ContainerConfig) GetCmd() []string { if m != nil { return m.Cmd } return nil } func (m *ContainerConfig) GetEnv() []string { if m != nil { return m.Env } return nil } func (m *ContainerConfig) GetUser() string { if m != nil { return m.User } return "" } func (m *ContainerConfig) GetNoUser() bool { if m != nil { return m.NoUser } return false } func (m *ContainerConfig) GetCwd() string { if m != nil { return m.Cwd } return "" } func (m *ContainerConfig) GetNoCwd() bool { if m != nil { return m.NoCwd } return false } func (m *ContainerConfig) GetTty() bool { if m != nil { return m.Tty } return false } type FdMessage struct { Fd uint32 `protobuf:"varint,1,opt,name=Fd,proto3" json:"Fd,omitempty"` EOF bool `protobuf:"varint,2,opt,name=EOF,proto3" json:"EOF,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *FdMessage) Reset() { *m = FdMessage{} } func (m *FdMessage) String() string { return proto.CompactTextString(m) } func (*FdMessage) ProtoMessage() {} func (*FdMessage) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{17} } func (m *FdMessage) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_FdMessage.Unmarshal(m, b) } func (m *FdMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_FdMessage.Marshal(b, m, deterministic) } func (m *FdMessage) XXX_Merge(src proto.Message) { xxx_messageInfo_FdMessage.Merge(m, src) } func (m *FdMessage) XXX_Size() int { return xxx_messageInfo_FdMessage.Size(m) } func (m *FdMessage) XXX_DiscardUnknown() { xxx_messageInfo_FdMessage.DiscardUnknown(m) } var xxx_messageInfo_FdMessage proto.InternalMessageInfo func (m *FdMessage) GetFd() uint32 { if m != nil { return m.Fd } return 0 } func (m *FdMessage) GetEOF() bool { if m != nil { return m.EOF } return false } func (m *FdMessage) GetData() []byte { if m != nil { return m.Data } return nil } type ResizeMessage struct { Rows uint32 `protobuf:"varint,1,opt,name=Rows,proto3" json:"Rows,omitempty"` Cols uint32 `protobuf:"varint,2,opt,name=Cols,proto3" json:"Cols,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ResizeMessage) Reset() { *m = ResizeMessage{} } func (m *ResizeMessage) String() string { return proto.CompactTextString(m) } func (*ResizeMessage) ProtoMessage() {} func (*ResizeMessage) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{18} } func (m *ResizeMessage) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ResizeMessage.Unmarshal(m, b) } func (m *ResizeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ResizeMessage.Marshal(b, m, deterministic) } func (m *ResizeMessage) XXX_Merge(src proto.Message) { xxx_messageInfo_ResizeMessage.Merge(m, src) } func (m *ResizeMessage) XXX_Size() int { return xxx_messageInfo_ResizeMessage.Size(m) } func (m *ResizeMessage) XXX_DiscardUnknown() { xxx_messageInfo_ResizeMessage.DiscardUnknown(m) } var xxx_messageInfo_ResizeMessage proto.InternalMessageInfo func (m *ResizeMessage) GetRows() uint32 { if m != nil { return m.Rows } return 0 } func (m *ResizeMessage) GetCols() uint32 { if m != nil { return m.Cols } return 0 } type SignalMessage struct { // we only send name (ie HUP, INT) because the int values // are platform dependent. Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *SignalMessage) Reset() { *m = SignalMessage{} } func (m *SignalMessage) String() string { return proto.CompactTextString(m) } func (*SignalMessage) ProtoMessage() {} func (*SignalMessage) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{19} } func (m *SignalMessage) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_SignalMessage.Unmarshal(m, b) } func (m *SignalMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_SignalMessage.Marshal(b, m, deterministic) } func (m *SignalMessage) XXX_Merge(src proto.Message) { xxx_messageInfo_SignalMessage.Merge(m, src) } func (m *SignalMessage) XXX_Size() int { return xxx_messageInfo_SignalMessage.Size(m) } func (m *SignalMessage) XXX_DiscardUnknown() { xxx_messageInfo_SignalMessage.DiscardUnknown(m) } var xxx_messageInfo_SignalMessage proto.InternalMessageInfo func (m *SignalMessage) GetName() string { if m != nil { return m.Name } return "" } type StatusRequest struct { Ref string `protobuf:"bytes,1,opt,name=Ref,proto3" json:"Ref,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *StatusRequest) Reset() { *m = StatusRequest{} } func (m *StatusRequest) String() string { return proto.CompactTextString(m) } func (*StatusRequest) ProtoMessage() {} func (*StatusRequest) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{20} } func (m *StatusRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_StatusRequest.Unmarshal(m, b) } func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_StatusRequest.Marshal(b, m, deterministic) } func (m *StatusRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_StatusRequest.Merge(m, src) } func (m *StatusRequest) XXX_Size() int { return xxx_messageInfo_StatusRequest.Size(m) } func (m *StatusRequest) XXX_DiscardUnknown() { xxx_messageInfo_StatusRequest.DiscardUnknown(m) } var xxx_messageInfo_StatusRequest proto.InternalMessageInfo func (m *StatusRequest) GetRef() string { if m != nil { return m.Ref } return "" } type StatusResponse struct { Vertexes []*control.Vertex `protobuf:"bytes,1,rep,name=vertexes,proto3" json:"vertexes,omitempty"` Statuses []*control.VertexStatus `protobuf:"bytes,2,rep,name=statuses,proto3" json:"statuses,omitempty"` Logs []*control.VertexLog `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"` Warnings []*control.VertexWarning `protobuf:"bytes,4,rep,name=warnings,proto3" json:"warnings,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *StatusResponse) Reset() { *m = StatusResponse{} } func (m *StatusResponse) String() string { return proto.CompactTextString(m) } func (*StatusResponse) ProtoMessage() {} func (*StatusResponse) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{21} } func (m *StatusResponse) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_StatusResponse.Unmarshal(m, b) } func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_StatusResponse.Marshal(b, m, deterministic) } func (m *StatusResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_StatusResponse.Merge(m, src) } func (m *StatusResponse) XXX_Size() int { return xxx_messageInfo_StatusResponse.Size(m) } func (m *StatusResponse) XXX_DiscardUnknown() { xxx_messageInfo_StatusResponse.DiscardUnknown(m) } var xxx_messageInfo_StatusResponse proto.InternalMessageInfo func (m *StatusResponse) GetVertexes() []*control.Vertex { if m != nil { return m.Vertexes } return nil } func (m *StatusResponse) GetStatuses() []*control.VertexStatus { if m != nil { return m.Statuses } return nil } func (m *StatusResponse) GetLogs() []*control.VertexLog { if m != nil { return m.Logs } return nil } func (m *StatusResponse) GetWarnings() []*control.VertexWarning { if m != nil { return m.Warnings } return nil } type InfoRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *InfoRequest) Reset() { *m = InfoRequest{} } func (m *InfoRequest) String() string { return proto.CompactTextString(m) } func (*InfoRequest) ProtoMessage() {} func (*InfoRequest) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{22} } func (m *InfoRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_InfoRequest.Unmarshal(m, b) } func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_InfoRequest.Marshal(b, m, deterministic) } func (m *InfoRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_InfoRequest.Merge(m, src) } func (m *InfoRequest) XXX_Size() int { return xxx_messageInfo_InfoRequest.Size(m) } func (m *InfoRequest) XXX_DiscardUnknown() { xxx_messageInfo_InfoRequest.DiscardUnknown(m) } var xxx_messageInfo_InfoRequest proto.InternalMessageInfo type InfoResponse struct { BuildxVersion *BuildxVersion `protobuf:"bytes,1,opt,name=buildxVersion,proto3" json:"buildxVersion,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *InfoResponse) Reset() { *m = InfoResponse{} } func (m *InfoResponse) String() string { return proto.CompactTextString(m) } func (*InfoResponse) ProtoMessage() {} func (*InfoResponse) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{23} } func (m *InfoResponse) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_InfoResponse.Unmarshal(m, b) } func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_InfoResponse.Marshal(b, m, deterministic) } func (m *InfoResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_InfoResponse.Merge(m, src) } func (m *InfoResponse) XXX_Size() int { return xxx_messageInfo_InfoResponse.Size(m) } func (m *InfoResponse) XXX_DiscardUnknown() { xxx_messageInfo_InfoResponse.DiscardUnknown(m) } var xxx_messageInfo_InfoResponse proto.InternalMessageInfo func (m *InfoResponse) GetBuildxVersion() *BuildxVersion { if m != nil { return m.BuildxVersion } return nil } type BuildxVersion struct { Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` Revision string `protobuf:"bytes,3,opt,name=revision,proto3" json:"revision,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *BuildxVersion) Reset() { *m = BuildxVersion{} } func (m *BuildxVersion) String() string { return proto.CompactTextString(m) } func (*BuildxVersion) ProtoMessage() {} func (*BuildxVersion) Descriptor() ([]byte, []int) { return fileDescriptor_ed7f10298fa1d90f, []int{24} } func (m *BuildxVersion) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_BuildxVersion.Unmarshal(m, b) } func (m *BuildxVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_BuildxVersion.Marshal(b, m, deterministic) } func (m *BuildxVersion) XXX_Merge(src proto.Message) { xxx_messageInfo_BuildxVersion.Merge(m, src) } func (m *BuildxVersion) XXX_Size() int { return xxx_messageInfo_BuildxVersion.Size(m) } func (m *BuildxVersion) XXX_DiscardUnknown() { xxx_messageInfo_BuildxVersion.DiscardUnknown(m) } var xxx_messageInfo_BuildxVersion proto.InternalMessageInfo func (m *BuildxVersion) GetPackage() string { if m != nil { return m.Package } return "" } func (m *BuildxVersion) GetVersion() string { if m != nil { return m.Version } return "" } func (m *BuildxVersion) GetRevision() string { if m != nil { return m.Revision } return "" } func init() { proto.RegisterType((*BuildRequest)(nil), "buildx.controller.v1.BuildRequest") proto.RegisterType((*BuildOptions)(nil), "buildx.controller.v1.BuildOptions") proto.RegisterType((*UlimitOpt)(nil), "buildx.controller.v1.UlimitOpt") proto.RegisterMapType((map[string]*Ulimit)(nil), "buildx.controller.v1.UlimitOpt.ValuesEntry") proto.RegisterType((*Ulimit)(nil), "buildx.controller.v1.Ulimit") proto.RegisterType((*CommonOptions)(nil), "buildx.controller.v1.CommonOptions") proto.RegisterType((*BuildResponse)(nil), "buildx.controller.v1.BuildResponse") proto.RegisterType((*DisconnectRequest)(nil), "buildx.controller.v1.DisconnectRequest") proto.RegisterType((*DisconnectResponse)(nil), "buildx.controller.v1.DisconnectResponse") proto.RegisterType((*ListRequest)(nil), "buildx.controller.v1.ListRequest") proto.RegisterType((*ListResponse)(nil), "buildx.controller.v1.ListResponse") proto.RegisterType((*InputMessage)(nil), "buildx.controller.v1.InputMessage") proto.RegisterType((*InputInitMessage)(nil), "buildx.controller.v1.InputInitMessage") proto.RegisterType((*DataMessage)(nil), "buildx.controller.v1.DataMessage") proto.RegisterType((*InputResponse)(nil), "buildx.controller.v1.InputResponse") proto.RegisterType((*Message)(nil), "buildx.controller.v1.Message") proto.RegisterType((*InitMessage)(nil), "buildx.controller.v1.InitMessage") proto.RegisterType((*ContainerConfig)(nil), "buildx.controller.v1.ContainerConfig") proto.RegisterType((*FdMessage)(nil), "buildx.controller.v1.FdMessage") proto.RegisterType((*ResizeMessage)(nil), "buildx.controller.v1.ResizeMessage") proto.RegisterType((*SignalMessage)(nil), "buildx.controller.v1.SignalMessage") proto.RegisterType((*StatusRequest)(nil), "buildx.controller.v1.StatusRequest") proto.RegisterType((*StatusResponse)(nil), "buildx.controller.v1.StatusResponse") proto.RegisterType((*InfoRequest)(nil), "buildx.controller.v1.InfoRequest") proto.RegisterType((*InfoResponse)(nil), "buildx.controller.v1.InfoResponse") proto.RegisterType((*BuildxVersion)(nil), "buildx.controller.v1.BuildxVersion") } func init() { proto.RegisterFile("controller.proto", fileDescriptor_ed7f10298fa1d90f) } var fileDescriptor_ed7f10298fa1d90f = []byte{ // 1436 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x57, 0xdd, 0x52, 0x1b, 0xc7, 0x12, 0x3e, 0x8b, 0x84, 0x7e, 0x5a, 0x08, 0xe3, 0x39, 0x1c, 0x9f, 0x39, 0x3a, 0x8e, 0x8d, 0x17, 0xdb, 0x51, 0x55, 0xaa, 0x84, 0x83, 0x93, 0x72, 0x62, 0x3b, 0x17, 0x20, 0xa0, 0x20, 0xc5, 0x5f, 0x16, 0x6c, 0x57, 0x72, 0x11, 0xd7, 0x22, 0x0d, 0x62, 0x4b, 0xab, 0x1d, 0x65, 0x67, 0x24, 0x20, 0x57, 0x79, 0x82, 0x5c, 0xe4, 0x2d, 0xf2, 0x0c, 0x79, 0x8d, 0xbc, 0x47, 0xf2, 0x08, 0xa9, 0xee, 0x99, 0x5d, 0x56, 0x58, 0x2b, 0x5f, 0x69, 0xfa, 0x9b, 0xef, 0xeb, 0x99, 0xee, 0xe9, 0xe9, 0x59, 0xc1, 0x52, 0x47, 0x46, 0x3a, 0x96, 0x61, 0x28, 0xe2, 0xd6, 0x30, 0x96, 0x5a, 0xb2, 0xe5, 0xb3, 0x51, 0x10, 0x76, 0xaf, 0x5a, 0x99, 0x89, 0xf1, 0xe7, 0x8d, 0x57, 0xbd, 0x40, 0x5f, 0x8c, 0xce, 0x5a, 0x1d, 0x39, 0x58, 0x1b, 0xc8, 0xb3, 0xeb, 0x35, 0x62, 0xf5, 0x03, 0xbd, 0xe6, 0x0f, 0x83, 0x35, 0x25, 0xe2, 0x71, 0xd0, 0x11, 0x6a, 0xcd, 0x8a, 0x92, 0x5f, 0xe3, 0xd2, 0xfd, 0x11, 0x16, 0x36, 0x91, 0xee, 0x89, 0x9f, 0x46, 0x42, 0x69, 0xb6, 0x04, 0x05, 0x4f, 0x9c, 0x73, 0x67, 0xc5, 0x69, 0x56, 0x3d, 0x1c, 0xb2, 0xd7, 0x50, 0x3e, 0x1a, 0xea, 0x40, 0x46, 0x8a, 0xcf, 0xad, 0x38, 0xcd, 0xda, 0xba, 0xdb, 0x9a, 0xb6, 0x8d, 0x16, 0xb9, 0xb1, 0x4c, 0x2f, 0x91, 0xb8, 0xbf, 0x95, 0xec, 0x02, 0x16, 0x60, 0x2b, 0x50, 0x6b, 0xcb, 0x48, 0x8b, 0x2b, 0x7d, 0xec, 0xeb, 0x0b, 0xbb, 0x50, 0x16, 0x62, 0x4f, 0x61, 0x71, 0x4b, 0x76, 0xfa, 0x22, 0x3e, 0x0f, 0x42, 0x71, 0xe8, 0x0f, 0x04, 0xad, 0x5b, 0xf5, 0x6e, 0xa1, 0xec, 0x3e, 0x54, 0x8f, 0xe3, 0x20, 0xd2, 0x3b, 0xa3, 0xa8, 0xc3, 0x0b, 0x44, 0xb9, 0x01, 0xd8, 0x32, 0xcc, 0x6f, 0x84, 0xa1, 0xbc, 0xe4, 0xc5, 0x95, 0x42, 0xb3, 0xea, 0x19, 0x83, 0x71, 0x28, 0x6f, 0x68, 0x2d, 0x94, 0x56, 0x7c, 0x9e, 0xf0, 0xc4, 0x44, 0x6f, 0xb4, 0xcf, 0x8d, 0xb8, 0xa7, 0x78, 0x89, 0xe6, 0x6e, 0x00, 0x9c, 0x6d, 0xfb, 0x9d, 0x0b, 0xb1, 0x13, 0xcb, 0x01, 0x2f, 0x9b, 0xd9, 0x14, 0x40, 0xaf, 0x64, 0x9c, 0x4a, 0x5e, 0x31, 0x5e, 0xad, 0xc9, 0x5c, 0x58, 0x68, 0xf7, 0x62, 0x39, 0x1a, 0x1e, 0xfb, 0xb1, 0x88, 0x34, 0xaf, 0xd2, 0x36, 0x27, 0x30, 0xd6, 0x80, 0x8a, 0x0d, 0x5f, 0x71, 0x20, 0x79, 0x6a, 0xb3, 0x07, 0x00, 0xdb, 0x57, 0x3a, 0xf6, 0x77, 0x25, 0x6e, 0xb9, 0x46, 0xb3, 0x19, 0x04, 0xb3, 0xb9, 0x37, 0xf0, 0x7b, 0x62, 0x6f, 0x6b, 0x27, 0x08, 0x05, 0x5f, 0x30, 0xd9, 0xcc, 0x40, 0xec, 0x1e, 0x94, 0xf6, 0xfd, 0x33, 0x11, 0x2a, 0x5e, 0x27, 0xb5, 0xb5, 0x50, 0x79, 0x28, 0xf4, 0xa5, 0x8c, 0xfb, 0x07, 0xb2, 0x2b, 0xf8, 0xa2, 0x51, 0x66, 0x20, 0xf6, 0x18, 0xea, 0x87, 0xd2, 0x04, 0x19, 0x84, 0x5a, 0xc4, 0xfc, 0x0e, 0x39, 0x98, 0x04, 0x31, 0xf6, 0xa3, 0x91, 0x1e, 0x8e, 0xb4, 0xe2, 0x4b, 0x26, 0x76, 0x6b, 0xd2, 0xf9, 0x84, 0xbe, 0x3e, 0x97, 0xf1, 0x40, 0xf1, 0xbb, 0x26, 0x67, 0x29, 0x80, 0xe7, 0xf3, 0xdd, 0x28, 0x10, 0x9a, 0xb3, 0x15, 0xa7, 0x59, 0xf1, 0x8c, 0x81, 0xde, 0x4e, 0x44, 0x27, 0x16, 0x5a, 0xf1, 0x7f, 0x1b, 0x6f, 0xd6, 0xa4, 0x99, 0x8b, 0xc1, 0x49, 0xf0, 0xb3, 0xe0, 0xcb, 0x2b, 0x4e, 0xb3, 0xe0, 0x25, 0x26, 0x96, 0xec, 0xc9, 0xc9, 0x2e, 0xff, 0x0f, 0xf1, 0x71, 0xc8, 0x18, 0x14, 0x4f, 0xfd, 0x9e, 0xe2, 0xf7, 0x08, 0xa2, 0x31, 0xe6, 0xe1, 0xd4, 0x8f, 0x7b, 0x42, 0xf3, 0xff, 0x52, 0xa8, 0xd6, 0x62, 0x5f, 0x43, 0xf9, 0x4d, 0x18, 0x0c, 0x02, 0xad, 0x38, 0xa7, 0xf2, 0x7e, 0x38, 0xbd, 0xbc, 0x0d, 0xe9, 0x68, 0xa8, 0xbd, 0x84, 0xcf, 0x5e, 0x40, 0xf1, 0x68, 0xa8, 0x15, 0xff, 0x1f, 0xe9, 0x56, 0xa7, 0xeb, 0xda, 0x72, 0x30, 0x90, 0x51, 0x72, 0x2f, 0x48, 0xe0, 0xfe, 0xee, 0x40, 0x35, 0xf5, 0xc7, 0xda, 0x50, 0x1a, 0xfb, 0xe1, 0x48, 0x28, 0xee, 0xac, 0x14, 0x9a, 0xb5, 0xf5, 0xcf, 0x3e, 0xb2, 0x81, 0xd6, 0x5b, 0x62, 0x6f, 0x47, 0x3a, 0xbe, 0xf6, 0xac, 0xb4, 0xf1, 0x0e, 0x6a, 0x19, 0x18, 0x73, 0xd2, 0x17, 0xd7, 0xc9, 0x35, 0xee, 0x8b, 0x6b, 0xb6, 0x0e, 0xf3, 0x44, 0xb5, 0x97, 0xf8, 0xfe, 0xac, 0x45, 0x3c, 0x43, 0x7d, 0x39, 0xf7, 0x95, 0xe3, 0x6e, 0x41, 0xc9, 0x80, 0x98, 0x55, 0xba, 0x8d, 0xc6, 0x29, 0x8d, 0x11, 0xdb, 0xf5, 0xe3, 0x2e, 0x39, 0x2d, 0x78, 0x34, 0x46, 0xec, 0x44, 0x9e, 0x6b, 0xba, 0x92, 0x05, 0x8f, 0xc6, 0xee, 0x5f, 0x0e, 0xd4, 0x27, 0x32, 0x81, 0xe7, 0x49, 0xd7, 0x4b, 0xc4, 0xd6, 0x61, 0x62, 0xe2, 0x9d, 0x39, 0x10, 0xda, 0xef, 0xfa, 0xda, 0xa7, 0xa2, 0x36, 0xb7, 0x7f, 0x02, 0x43, 0xb5, 0x2d, 0x43, 0x5a, 0xa6, 0xe2, 0x25, 0x26, 0xae, 0x7e, 0x3c, 0x0a, 0x43, 0x5e, 0x24, 0x98, 0xc6, 0xe6, 0x16, 0x0d, 0x65, 0xac, 0x8f, 0x47, 0xea, 0x82, 0xcf, 0xd3, 0x4c, 0x06, 0xb9, 0x99, 0xdf, 0x97, 0x7e, 0x97, 0x97, 0xb2, 0xf3, 0x88, 0x50, 0x44, 0x9b, 0x47, 0x07, 0xbc, 0x6c, 0x22, 0xc7, 0x31, 0x6a, 0x8e, 0x63, 0x39, 0x16, 0x91, 0x1f, 0x75, 0x04, 0xaf, 0xd0, 0x4c, 0x06, 0x71, 0xef, 0x40, 0xdd, 0x36, 0x56, 0x35, 0x94, 0x91, 0x12, 0xee, 0x13, 0xb8, 0xbb, 0x15, 0xa8, 0x8e, 0x8c, 0x22, 0xd1, 0xd1, 0xb9, 0xed, 0xd6, 0x5d, 0x06, 0x96, 0xa5, 0x59, 0xf1, 0x43, 0xa8, 0xed, 0x07, 0x6a, 0x86, 0xcc, 0x85, 0x05, 0x43, 0x30, 0x02, 0xdc, 0x72, 0x5f, 0x5c, 0x9b, 0x92, 0xaa, 0x7a, 0x34, 0x76, 0x7f, 0x75, 0x60, 0x61, 0x2f, 0x1a, 0x8e, 0xf4, 0x81, 0x50, 0xca, 0xef, 0x09, 0xf6, 0x1a, 0x8a, 0x7b, 0x51, 0xa0, 0xc9, 0x4f, 0x6d, 0xfd, 0xe9, 0xf4, 0x92, 0x20, 0x05, 0xd2, 0xac, 0x6a, 0xf7, 0x5f, 0x1e, 0xa9, 0xb0, 0xfc, 0xb7, 0x7c, 0xed, 0xdb, 0x82, 0x7a, 0x34, 0x5d, 0x8d, 0x8c, 0x8c, 0x10, 0xcd, 0xcd, 0x32, 0xcc, 0x93, 0x53, 0xf7, 0x31, 0x2c, 0xdd, 0xf6, 0x3e, 0x25, 0xb4, 0xe7, 0x50, 0xcb, 0x78, 0x41, 0xc2, 0xf6, 0xd1, 0x0e, 0x11, 0x2a, 0x1e, 0x0e, 0x31, 0xd6, 0x74, 0x23, 0x0b, 0x66, 0x0d, 0x4c, 0x3f, 0xb9, 0x4e, 0x33, 0xf8, 0xcb, 0x1c, 0x94, 0x13, 0x17, 0x2f, 0x26, 0xe2, 0x7e, 0x94, 0x17, 0xf7, 0x87, 0x21, 0x7f, 0x09, 0xc5, 0xb4, 0x24, 0x73, 0x3b, 0xc5, 0x4e, 0x37, 0x23, 0xa3, 0x6a, 0xfd, 0x06, 0x4a, 0x9e, 0x50, 0xd8, 0xba, 0x0a, 0xb3, 0x5a, 0x85, 0xe1, 0xdc, 0x88, 0xad, 0x08, 0xe5, 0x27, 0x41, 0x2f, 0xf2, 0x4d, 0x51, 0xe7, 0xca, 0x0d, 0x27, 0x23, 0x37, 0xc0, 0x4d, 0xba, 0x87, 0x50, 0x9b, 0x99, 0x69, 0x76, 0x04, 0x77, 0xf0, 0xe5, 0xf1, 0x83, 0x48, 0xc4, 0x6d, 0x19, 0x9d, 0x07, 0x3d, 0x1b, 0xe9, 0x93, 0xbc, 0xde, 0x36, 0x41, 0xf6, 0x6e, 0xab, 0xdd, 0x3f, 0x9c, 0x0f, 0x3c, 0xd2, 0x65, 0xc3, 0x1e, 0x35, 0x94, 0x41, 0xa4, 0x6d, 0x7d, 0x66, 0x10, 0xdc, 0x56, 0x7b, 0x80, 0x1d, 0x85, 0xda, 0x79, 0x7b, 0xd0, 0xa5, 0x13, 0x8f, 0xc6, 0xbc, 0x60, 0x90, 0xed, 0x68, 0x8c, 0x27, 0xfe, 0x46, 0x89, 0x98, 0xf2, 0x51, 0xf5, 0x68, 0x8c, 0x0d, 0xfe, 0x50, 0x12, 0x6a, 0x2e, 0xb8, 0xb5, 0xc8, 0xdf, 0xa5, 0xb9, 0xd5, 0xe8, 0xef, 0xb2, 0x8b, 0x4f, 0xcf, 0xa1, 0x44, 0xac, 0x6c, 0x9e, 0x1e, 0x32, 0x90, 0x77, 0xaa, 0xaf, 0xe9, 0x26, 0x57, 0x3c, 0x1c, 0xba, 0x1b, 0x50, 0x4d, 0xcf, 0x92, 0x2d, 0xc2, 0xdc, 0x4e, 0x97, 0x92, 0x55, 0xf7, 0xe6, 0x76, 0xba, 0x49, 0x19, 0xce, 0x7d, 0x58, 0x86, 0x85, 0x4c, 0x19, 0xbe, 0x80, 0xfa, 0xc4, 0xa9, 0x22, 0xc9, 0x93, 0x97, 0xca, 0x3a, 0xa2, 0x31, 0x62, 0x6d, 0x19, 0x9a, 0xcf, 0xab, 0xba, 0x47, 0x63, 0x77, 0x15, 0xea, 0x13, 0xe7, 0x39, 0xad, 0xfb, 0xba, 0x8f, 0xa0, 0x7e, 0xa2, 0x7d, 0x3d, 0x52, 0xf9, 0x7d, 0xe1, 0x6f, 0x07, 0x16, 0x13, 0x8e, 0x6d, 0x0d, 0x5f, 0x40, 0x65, 0x2c, 0x62, 0x2d, 0xae, 0xd2, 0x17, 0x87, 0xb7, 0xf0, 0xbb, 0xb1, 0x95, 0x7c, 0x37, 0xe2, 0xd1, 0xbe, 0x25, 0x86, 0x97, 0x32, 0xd9, 0x4b, 0xa8, 0x28, 0xf2, 0x23, 0x14, 0x9d, 0x4d, 0x6d, 0xfd, 0x41, 0x9e, 0xca, 0xae, 0x97, 0xf2, 0xd9, 0x1a, 0x14, 0x43, 0xd9, 0x53, 0x74, 0x82, 0xb5, 0xf5, 0xff, 0xe7, 0xe9, 0xf6, 0x65, 0xcf, 0x23, 0x22, 0x7b, 0x05, 0x95, 0x4b, 0x3f, 0x8e, 0x82, 0xa8, 0xa7, 0xe8, 0xfb, 0x0d, 0xef, 0x5a, 0x8e, 0xe8, 0x9d, 0xe1, 0x79, 0xa9, 0xc0, 0xad, 0x63, 0x99, 0x9f, 0x4b, 0x9b, 0x13, 0xf7, 0x7b, 0x6c, 0x7a, 0x68, 0xda, 0xf0, 0xf7, 0xa0, 0x6e, 0x8a, 0xf9, 0xad, 0x88, 0x55, 0x20, 0x23, 0xdb, 0x05, 0x56, 0x67, 0x7c, 0xd5, 0x26, 0x54, 0x6f, 0x52, 0xe9, 0xbe, 0xb7, 0x3d, 0x3e, 0x01, 0xf0, 0x59, 0x1a, 0xfa, 0x9d, 0xbe, 0xdf, 0x4b, 0xce, 0x29, 0x31, 0x71, 0x66, 0x6c, 0xd7, 0x33, 0xef, 0x59, 0x62, 0xe2, 0xe7, 0x5f, 0x2c, 0xc6, 0x01, 0x4d, 0x99, 0xaf, 0xd8, 0xd4, 0x5e, 0xff, 0xb3, 0x08, 0xd0, 0x4e, 0xf7, 0xc3, 0x8e, 0x61, 0x9e, 0xd6, 0x63, 0xb3, 0x3e, 0xc1, 0x6d, 0xdc, 0x8d, 0xd5, 0x99, 0x1c, 0x9b, 0x8c, 0x37, 0x50, 0x32, 0xa7, 0xc5, 0xf2, 0x9a, 0x4a, 0xb6, 0xbe, 0x1a, 0x8f, 0x67, 0x93, 0x8c, 0xd3, 0x67, 0x0e, 0xf3, 0x6c, 0xcb, 0xc9, 0xdb, 0x68, 0xf6, 0x15, 0xca, 0xdb, 0xe8, 0x44, 0xfb, 0x6e, 0x3a, 0xec, 0x5b, 0x28, 0xed, 0x45, 0x63, 0xd9, 0x17, 0xec, 0x93, 0xe9, 0x82, 0xc4, 0xdf, 0xec, 0xe9, 0xa6, 0xf3, 0xcc, 0x61, 0x07, 0x50, 0xc4, 0xd7, 0x92, 0xe5, 0xb4, 0xfe, 0xcc, 0x53, 0xdb, 0x70, 0x67, 0x51, 0x6c, 0x16, 0xdf, 0x03, 0xdc, 0xbc, 0xd9, 0xec, 0xd3, 0x9c, 0x97, 0xf0, 0xf6, 0xe3, 0xdf, 0x68, 0x7e, 0x9c, 0x68, 0x17, 0x38, 0xc0, 0x07, 0xeb, 0x5c, 0xb2, 0xdc, 0xa7, 0x2a, 0x2d, 0xf7, 0x86, 0x3b, 0x8b, 0x62, 0xdc, 0x6d, 0x16, 0x7f, 0x98, 0x1b, 0x9e, 0x9d, 0x95, 0xe8, 0x1f, 0xe0, 0xf3, 0x7f, 0x02, 0x00, 0x00, 0xff, 0xff, 0x10, 0xcd, 0x98, 0x21, 0x68, 0x0e, 0x00, 0x00, } // Reference imports to suppress errors if they are not otherwise used. var _ context.Context var _ grpc.ClientConn // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. const _ = grpc.SupportPackageIsVersion4 // ControllerClient is the client API for Controller service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. type ControllerClient interface { Build(ctx context.Context, in *BuildRequest, opts ...grpc.CallOption) (*BuildResponse, error) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (Controller_StatusClient, error) Input(ctx context.Context, opts ...grpc.CallOption) (Controller_InputClient, error) Invoke(ctx context.Context, opts ...grpc.CallOption) (Controller_InvokeClient, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) Disconnect(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectResponse, error) Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error) } type controllerClient struct { cc *grpc.ClientConn } func NewControllerClient(cc *grpc.ClientConn) ControllerClient { return &controllerClient{cc} } func (c *controllerClient) Build(ctx context.Context, in *BuildRequest, opts ...grpc.CallOption) (*BuildResponse, error) { out := new(BuildResponse) err := c.cc.Invoke(ctx, "/buildx.controller.v1.Controller/Build", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *controllerClient) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (Controller_StatusClient, error) { stream, err := c.cc.NewStream(ctx, &_Controller_serviceDesc.Streams[0], "/buildx.controller.v1.Controller/Status", opts...) if err != nil { return nil, err } x := &controllerStatusClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } if err := x.ClientStream.CloseSend(); err != nil { return nil, err } return x, nil } type Controller_StatusClient interface { Recv() (*StatusResponse, error) grpc.ClientStream } type controllerStatusClient struct { grpc.ClientStream } func (x *controllerStatusClient) Recv() (*StatusResponse, error) { m := new(StatusResponse) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *controllerClient) Input(ctx context.Context, opts ...grpc.CallOption) (Controller_InputClient, error) { stream, err := c.cc.NewStream(ctx, &_Controller_serviceDesc.Streams[1], "/buildx.controller.v1.Controller/Input", opts...) if err != nil { return nil, err } x := &controllerInputClient{stream} return x, nil } type Controller_InputClient interface { Send(*InputMessage) error CloseAndRecv() (*InputResponse, error) grpc.ClientStream } type controllerInputClient struct { grpc.ClientStream } func (x *controllerInputClient) Send(m *InputMessage) error { return x.ClientStream.SendMsg(m) } func (x *controllerInputClient) CloseAndRecv() (*InputResponse, error) { if err := x.ClientStream.CloseSend(); err != nil { return nil, err } m := new(InputResponse) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *controllerClient) Invoke(ctx context.Context, opts ...grpc.CallOption) (Controller_InvokeClient, error) { stream, err := c.cc.NewStream(ctx, &_Controller_serviceDesc.Streams[2], "/buildx.controller.v1.Controller/Invoke", opts...) if err != nil { return nil, err } x := &controllerInvokeClient{stream} return x, nil } type Controller_InvokeClient interface { Send(*Message) error Recv() (*Message, error) grpc.ClientStream } type controllerInvokeClient struct { grpc.ClientStream } func (x *controllerInvokeClient) Send(m *Message) error { return x.ClientStream.SendMsg(m) } func (x *controllerInvokeClient) Recv() (*Message, error) { m := new(Message) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *controllerClient) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) { out := new(ListResponse) err := c.cc.Invoke(ctx, "/buildx.controller.v1.Controller/List", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *controllerClient) Disconnect(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectResponse, error) { out := new(DisconnectResponse) err := c.cc.Invoke(ctx, "/buildx.controller.v1.Controller/Disconnect", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *controllerClient) Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error) { out := new(InfoResponse) err := c.cc.Invoke(ctx, "/buildx.controller.v1.Controller/Info", in, out, opts...) if err != nil { return nil, err } return out, nil } // ControllerServer is the server API for Controller service. type ControllerServer interface { Build(context.Context, *BuildRequest) (*BuildResponse, error) Status(*StatusRequest, Controller_StatusServer) error Input(Controller_InputServer) error Invoke(Controller_InvokeServer) error List(context.Context, *ListRequest) (*ListResponse, error) Disconnect(context.Context, *DisconnectRequest) (*DisconnectResponse, error) Info(context.Context, *InfoRequest) (*InfoResponse, error) } // UnimplementedControllerServer can be embedded to have forward compatible implementations. type UnimplementedControllerServer struct { } func (*UnimplementedControllerServer) Build(ctx context.Context, req *BuildRequest) (*BuildResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method Build not implemented") } func (*UnimplementedControllerServer) Status(req *StatusRequest, srv Controller_StatusServer) error { return status.Errorf(codes.Unimplemented, "method Status not implemented") } func (*UnimplementedControllerServer) Input(srv Controller_InputServer) error { return status.Errorf(codes.Unimplemented, "method Input not implemented") } func (*UnimplementedControllerServer) Invoke(srv Controller_InvokeServer) error { return status.Errorf(codes.Unimplemented, "method Invoke not implemented") } func (*UnimplementedControllerServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method List not implemented") } func (*UnimplementedControllerServer) Disconnect(ctx context.Context, req *DisconnectRequest) (*DisconnectResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method Disconnect not implemented") } func (*UnimplementedControllerServer) Info(ctx context.Context, req *InfoRequest) (*InfoResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method Info not implemented") } func RegisterControllerServer(s *grpc.Server, srv ControllerServer) { s.RegisterService(&_Controller_serviceDesc, srv) } func _Controller_Build_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(BuildRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ControllerServer).Build(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/buildx.controller.v1.Controller/Build", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ControllerServer).Build(ctx, req.(*BuildRequest)) } return interceptor(ctx, in, info, handler) } func _Controller_Status_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(StatusRequest) if err := stream.RecvMsg(m); err != nil { return err } return srv.(ControllerServer).Status(m, &controllerStatusServer{stream}) } type Controller_StatusServer interface { Send(*StatusResponse) error grpc.ServerStream } type controllerStatusServer struct { grpc.ServerStream } func (x *controllerStatusServer) Send(m *StatusResponse) error { return x.ServerStream.SendMsg(m) } func _Controller_Input_Handler(srv interface{}, stream grpc.ServerStream) error { return srv.(ControllerServer).Input(&controllerInputServer{stream}) } type Controller_InputServer interface { SendAndClose(*InputResponse) error Recv() (*InputMessage, error) grpc.ServerStream } type controllerInputServer struct { grpc.ServerStream } func (x *controllerInputServer) SendAndClose(m *InputResponse) error { return x.ServerStream.SendMsg(m) } func (x *controllerInputServer) Recv() (*InputMessage, error) { m := new(InputMessage) if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func _Controller_Invoke_Handler(srv interface{}, stream grpc.ServerStream) error { return srv.(ControllerServer).Invoke(&controllerInvokeServer{stream}) } type Controller_InvokeServer interface { Send(*Message) error Recv() (*Message, error) grpc.ServerStream } type controllerInvokeServer struct { grpc.ServerStream } func (x *controllerInvokeServer) Send(m *Message) error { return x.ServerStream.SendMsg(m) } func (x *controllerInvokeServer) Recv() (*Message, error) { m := new(Message) if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func _Controller_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ControllerServer).List(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/buildx.controller.v1.Controller/List", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ControllerServer).List(ctx, req.(*ListRequest)) } return interceptor(ctx, in, info, handler) } func _Controller_Disconnect_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DisconnectRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ControllerServer).Disconnect(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/buildx.controller.v1.Controller/Disconnect", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ControllerServer).Disconnect(ctx, req.(*DisconnectRequest)) } return interceptor(ctx, in, info, handler) } func _Controller_Info_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(InfoRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ControllerServer).Info(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/buildx.controller.v1.Controller/Info", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ControllerServer).Info(ctx, req.(*InfoRequest)) } return interceptor(ctx, in, info, handler) } var _Controller_serviceDesc = grpc.ServiceDesc{ ServiceName: "buildx.controller.v1.Controller", HandlerType: (*ControllerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Build", Handler: _Controller_Build_Handler, }, { MethodName: "List", Handler: _Controller_List_Handler, }, { MethodName: "Disconnect", Handler: _Controller_Disconnect_Handler, }, { MethodName: "Info", Handler: _Controller_Info_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Status", Handler: _Controller_Status_Handler, ServerStreams: true, }, { StreamName: "Input", Handler: _Controller_Input_Handler, ClientStreams: true, }, { StreamName: "Invoke", Handler: _Controller_Invoke_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "controller.proto", }