Versions in this module Expand all Collapse all v0 v0.3.3 Nov 21, 2018 v0.3.2 Oct 31, 2018 v0.3.1 Oct 17, 2018 v0.3.0 Oct 12, 2018 Changes in this version + var ErrIntOverflowControl = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthControl = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterControlServer(s *grpc.Server, srv ControlServer) + type BytesMessage struct + Data []byte + func (*BytesMessage) Descriptor() ([]byte, []int) + func (*BytesMessage) ProtoMessage() + func (m *BytesMessage) GetData() []byte + func (m *BytesMessage) Marshal() (dAtA []byte, err error) + func (m *BytesMessage) MarshalTo(dAtA []byte) (int, error) + func (m *BytesMessage) Reset() + func (m *BytesMessage) Size() (n int) + func (m *BytesMessage) String() string + func (m *BytesMessage) Unmarshal(dAtA []byte) error + type CacheOptions struct + ExportAttrs map[string]string + ExportRef string + ImportRefs []string + func (*CacheOptions) Descriptor() ([]byte, []int) + func (*CacheOptions) ProtoMessage() + func (m *CacheOptions) GetExportAttrs() map[string]string + func (m *CacheOptions) GetExportRef() string + func (m *CacheOptions) GetImportRefs() []string + func (m *CacheOptions) Marshal() (dAtA []byte, err error) + func (m *CacheOptions) MarshalTo(dAtA []byte) (int, error) + func (m *CacheOptions) Reset() + func (m *CacheOptions) Size() (n int) + func (m *CacheOptions) String() string + func (m *CacheOptions) Unmarshal(dAtA []byte) error + type ControlClient interface + DiskUsage func(ctx context.Context, in *DiskUsageRequest, opts ...grpc.CallOption) (*DiskUsageResponse, error) + ListWorkers func(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*ListWorkersResponse, error) + Prune func(ctx context.Context, in *PruneRequest, opts ...grpc.CallOption) (Control_PruneClient, error) + Session func(ctx context.Context, opts ...grpc.CallOption) (Control_SessionClient, error) + Solve func(ctx context.Context, in *SolveRequest, opts ...grpc.CallOption) (*SolveResponse, error) + Status func(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (Control_StatusClient, error) + func NewControlClient(cc *grpc.ClientConn) ControlClient + type ControlServer interface + DiskUsage func(context.Context, *DiskUsageRequest) (*DiskUsageResponse, error) + ListWorkers func(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error) + Prune func(*PruneRequest, Control_PruneServer) error + Session func(Control_SessionServer) error + Solve func(context.Context, *SolveRequest) (*SolveResponse, error) + Status func(*StatusRequest, Control_StatusServer) error + type Control_PruneClient interface + Recv func() (*UsageRecord, error) + type Control_PruneServer interface + Send func(*UsageRecord) error + type Control_SessionClient interface + Recv func() (*BytesMessage, error) + Send func(*BytesMessage) error + type Control_SessionServer interface + Recv func() (*BytesMessage, error) + Send func(*BytesMessage) error + type Control_StatusClient interface + Recv func() (*StatusResponse, error) + type Control_StatusServer interface + Send func(*StatusResponse) error + type DiskUsageRequest struct + Filter []string + func (*DiskUsageRequest) Descriptor() ([]byte, []int) + func (*DiskUsageRequest) ProtoMessage() + func (m *DiskUsageRequest) GetFilter() []string + func (m *DiskUsageRequest) Marshal() (dAtA []byte, err error) + func (m *DiskUsageRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DiskUsageRequest) Reset() + func (m *DiskUsageRequest) Size() (n int) + func (m *DiskUsageRequest) String() string + func (m *DiskUsageRequest) Unmarshal(dAtA []byte) error + type DiskUsageResponse struct + Record []*UsageRecord + func (*DiskUsageResponse) Descriptor() ([]byte, []int) + func (*DiskUsageResponse) ProtoMessage() + func (m *DiskUsageResponse) GetRecord() []*UsageRecord + func (m *DiskUsageResponse) Marshal() (dAtA []byte, err error) + func (m *DiskUsageResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DiskUsageResponse) Reset() + func (m *DiskUsageResponse) Size() (n int) + func (m *DiskUsageResponse) String() string + func (m *DiskUsageResponse) Unmarshal(dAtA []byte) error + type ListWorkersRequest struct + Filter []string + func (*ListWorkersRequest) Descriptor() ([]byte, []int) + func (*ListWorkersRequest) ProtoMessage() + func (m *ListWorkersRequest) GetFilter() []string + func (m *ListWorkersRequest) Marshal() (dAtA []byte, err error) + func (m *ListWorkersRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListWorkersRequest) Reset() + func (m *ListWorkersRequest) Size() (n int) + func (m *ListWorkersRequest) String() string + func (m *ListWorkersRequest) Unmarshal(dAtA []byte) error + type ListWorkersResponse struct + Record []*moby_buildkit_v1_types.WorkerRecord + func (*ListWorkersResponse) Descriptor() ([]byte, []int) + func (*ListWorkersResponse) ProtoMessage() + func (m *ListWorkersResponse) GetRecord() []*moby_buildkit_v1_types.WorkerRecord + func (m *ListWorkersResponse) Marshal() (dAtA []byte, err error) + func (m *ListWorkersResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListWorkersResponse) Reset() + func (m *ListWorkersResponse) Size() (n int) + func (m *ListWorkersResponse) String() string + func (m *ListWorkersResponse) Unmarshal(dAtA []byte) error + type PruneRequest struct + All bool + Filter []string + KeepBytes int64 + KeepDuration int64 + func (*PruneRequest) Descriptor() ([]byte, []int) + func (*PruneRequest) ProtoMessage() + func (m *PruneRequest) GetAll() bool + func (m *PruneRequest) GetFilter() []string + func (m *PruneRequest) GetKeepBytes() int64 + func (m *PruneRequest) GetKeepDuration() int64 + func (m *PruneRequest) Marshal() (dAtA []byte, err error) + func (m *PruneRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PruneRequest) Reset() + func (m *PruneRequest) Size() (n int) + func (m *PruneRequest) String() string + func (m *PruneRequest) Unmarshal(dAtA []byte) error + type SolveRequest struct + Cache CacheOptions + Definition *pb.Definition + Entitlements []github_com_moby_buildkit_util_entitlements.Entitlement + Exporter string + ExporterAttrs map[string]string + Frontend string + FrontendAttrs map[string]string + Ref string + Session string + func (*SolveRequest) Descriptor() ([]byte, []int) + func (*SolveRequest) ProtoMessage() + func (m *SolveRequest) GetCache() CacheOptions + func (m *SolveRequest) GetDefinition() *pb.Definition + func (m *SolveRequest) GetExporter() string + func (m *SolveRequest) GetExporterAttrs() map[string]string + func (m *SolveRequest) GetFrontend() string + func (m *SolveRequest) GetFrontendAttrs() map[string]string + func (m *SolveRequest) GetRef() string + func (m *SolveRequest) GetSession() string + func (m *SolveRequest) Marshal() (dAtA []byte, err error) + func (m *SolveRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SolveRequest) Reset() + func (m *SolveRequest) Size() (n int) + func (m *SolveRequest) String() string + func (m *SolveRequest) Unmarshal(dAtA []byte) error + type SolveResponse struct + ExporterResponse map[string]string + func (*SolveResponse) Descriptor() ([]byte, []int) + func (*SolveResponse) ProtoMessage() + func (m *SolveResponse) GetExporterResponse() map[string]string + func (m *SolveResponse) Marshal() (dAtA []byte, err error) + func (m *SolveResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SolveResponse) Reset() + func (m *SolveResponse) Size() (n int) + func (m *SolveResponse) String() string + func (m *SolveResponse) Unmarshal(dAtA []byte) error + type StatusRequest struct + Ref string + func (*StatusRequest) Descriptor() ([]byte, []int) + func (*StatusRequest) ProtoMessage() + func (m *StatusRequest) GetRef() string + func (m *StatusRequest) Marshal() (dAtA []byte, err error) + func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StatusRequest) Reset() + func (m *StatusRequest) Size() (n int) + func (m *StatusRequest) String() string + func (m *StatusRequest) Unmarshal(dAtA []byte) error + type StatusResponse struct + Logs []*VertexLog + Statuses []*VertexStatus + Vertexes []*Vertex + func (*StatusResponse) Descriptor() ([]byte, []int) + func (*StatusResponse) ProtoMessage() + func (m *StatusResponse) GetLogs() []*VertexLog + func (m *StatusResponse) GetStatuses() []*VertexStatus + func (m *StatusResponse) GetVertexes() []*Vertex + func (m *StatusResponse) Marshal() (dAtA []byte, err error) + func (m *StatusResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StatusResponse) Reset() + func (m *StatusResponse) Size() (n int) + func (m *StatusResponse) String() string + func (m *StatusResponse) Unmarshal(dAtA []byte) error + type UsageRecord struct + CreatedAt time.Time + Description string + ID string + InUse bool + LastUsedAt *time.Time + Mutable bool + Parent string + RecordType string + Shared bool + Size_ int64 + UsageCount int64 + func (*UsageRecord) Descriptor() ([]byte, []int) + func (*UsageRecord) ProtoMessage() + func (m *UsageRecord) GetCreatedAt() time.Time + func (m *UsageRecord) GetDescription() string + func (m *UsageRecord) GetID() string + func (m *UsageRecord) GetInUse() bool + func (m *UsageRecord) GetLastUsedAt() *time.Time + func (m *UsageRecord) GetMutable() bool + func (m *UsageRecord) GetParent() string + func (m *UsageRecord) GetRecordType() string + func (m *UsageRecord) GetShared() bool + func (m *UsageRecord) GetSize_() int64 + func (m *UsageRecord) GetUsageCount() int64 + func (m *UsageRecord) Marshal() (dAtA []byte, err error) + func (m *UsageRecord) MarshalTo(dAtA []byte) (int, error) + func (m *UsageRecord) Reset() + func (m *UsageRecord) Size() (n int) + func (m *UsageRecord) String() string + func (m *UsageRecord) Unmarshal(dAtA []byte) error + type Vertex struct + Cached bool + Completed *time.Time + Digest github_com_opencontainers_go_digest.Digest + Error string + Inputs []github_com_opencontainers_go_digest.Digest + Name string + Started *time.Time + func (*Vertex) Descriptor() ([]byte, []int) + func (*Vertex) ProtoMessage() + func (m *Vertex) GetCached() bool + func (m *Vertex) GetCompleted() *time.Time + func (m *Vertex) GetError() string + func (m *Vertex) GetName() string + func (m *Vertex) GetStarted() *time.Time + func (m *Vertex) Marshal() (dAtA []byte, err error) + func (m *Vertex) MarshalTo(dAtA []byte) (int, error) + func (m *Vertex) Reset() + func (m *Vertex) Size() (n int) + func (m *Vertex) String() string + func (m *Vertex) Unmarshal(dAtA []byte) error + type VertexLog struct + Msg []byte + Stream int64 + Timestamp time.Time + Vertex github_com_opencontainers_go_digest.Digest + func (*VertexLog) Descriptor() ([]byte, []int) + func (*VertexLog) ProtoMessage() + func (m *VertexLog) GetMsg() []byte + func (m *VertexLog) GetStream() int64 + func (m *VertexLog) GetTimestamp() time.Time + func (m *VertexLog) Marshal() (dAtA []byte, err error) + func (m *VertexLog) MarshalTo(dAtA []byte) (int, error) + func (m *VertexLog) Reset() + func (m *VertexLog) Size() (n int) + func (m *VertexLog) String() string + func (m *VertexLog) Unmarshal(dAtA []byte) error + type VertexStatus struct + Completed *time.Time + Current int64 + ID string + Name string + Started *time.Time + Timestamp time.Time + Total int64 + Vertex github_com_opencontainers_go_digest.Digest + func (*VertexStatus) Descriptor() ([]byte, []int) + func (*VertexStatus) ProtoMessage() + func (m *VertexStatus) GetCompleted() *time.Time + func (m *VertexStatus) GetCurrent() int64 + func (m *VertexStatus) GetID() string + func (m *VertexStatus) GetName() string + func (m *VertexStatus) GetStarted() *time.Time + func (m *VertexStatus) GetTimestamp() time.Time + func (m *VertexStatus) GetTotal() int64 + func (m *VertexStatus) Marshal() (dAtA []byte, err error) + func (m *VertexStatus) MarshalTo(dAtA []byte) (int, error) + func (m *VertexStatus) Reset() + func (m *VertexStatus) Size() (n int) + func (m *VertexStatus) String() string + func (m *VertexStatus) Unmarshal(dAtA []byte) error