Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthDiff        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDiff          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDiff = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterDiffServer

func RegisterDiffServer(s *grpc.Server, srv DiffServer)

Types

type ApplyRequest

type ApplyRequest struct {
	// Diff is the descriptor of the diff to be extracted
	Diff                 *types.Descriptor      `protobuf:"bytes,1,opt,name=diff,proto3" json:"diff,omitempty"`
	Mounts               []*types.Mount         `protobuf:"bytes,2,rep,name=mounts,proto3" json:"mounts,omitempty"`
	Payloads             map[string]*types1.Any `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ApplyRequest) Descriptor

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

func (*ApplyRequest) Marshal

func (m *ApplyRequest) Marshal() (dAtA []byte, err error)

func (*ApplyRequest) MarshalTo

func (m *ApplyRequest) MarshalTo(dAtA []byte) (int, error)

func (*ApplyRequest) MarshalToSizedBuffer

func (m *ApplyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ApplyRequest) ProtoMessage

func (*ApplyRequest) ProtoMessage()

func (*ApplyRequest) Reset

func (m *ApplyRequest) Reset()

func (*ApplyRequest) Size

func (m *ApplyRequest) Size() (n int)

func (*ApplyRequest) String

func (this *ApplyRequest) String() string

func (*ApplyRequest) Unmarshal

func (m *ApplyRequest) Unmarshal(dAtA []byte) error

func (*ApplyRequest) XXX_DiscardUnknown

func (m *ApplyRequest) XXX_DiscardUnknown()

func (*ApplyRequest) XXX_Marshal

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

func (*ApplyRequest) XXX_Merge

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

func (*ApplyRequest) XXX_Size

func (m *ApplyRequest) XXX_Size() int

func (*ApplyRequest) XXX_Unmarshal

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

type ApplyResponse

type ApplyResponse struct {
	// Applied is the descriptor for the object which was applied.
	// If the input was a compressed blob then the result will be
	// the descriptor for the uncompressed blob.
	Applied              *types.Descriptor `protobuf:"bytes,1,opt,name=applied,proto3" json:"applied,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ApplyResponse) Descriptor

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

func (*ApplyResponse) Marshal

func (m *ApplyResponse) Marshal() (dAtA []byte, err error)

func (*ApplyResponse) MarshalTo

func (m *ApplyResponse) MarshalTo(dAtA []byte) (int, error)

func (*ApplyResponse) MarshalToSizedBuffer

func (m *ApplyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ApplyResponse) ProtoMessage

func (*ApplyResponse) ProtoMessage()

func (*ApplyResponse) Reset

func (m *ApplyResponse) Reset()

func (*ApplyResponse) Size

func (m *ApplyResponse) Size() (n int)

func (*ApplyResponse) String

func (this *ApplyResponse) String() string

func (*ApplyResponse) Unmarshal

func (m *ApplyResponse) Unmarshal(dAtA []byte) error

func (*ApplyResponse) XXX_DiscardUnknown

func (m *ApplyResponse) XXX_DiscardUnknown()

func (*ApplyResponse) XXX_Marshal

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

func (*ApplyResponse) XXX_Merge

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

func (*ApplyResponse) XXX_Size

func (m *ApplyResponse) XXX_Size() int

func (*ApplyResponse) XXX_Unmarshal

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

type DiffClient

type DiffClient interface {
	// Apply applies the content associated with the provided digests onto
	// the provided mounts. Archive content will be extracted and
	// decompressed if necessary.
	Apply(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)
	// Diff creates a diff between the given mounts and uploads the result
	// to the content store.
	Diff(ctx context.Context, in *DiffRequest, opts ...grpc.CallOption) (*DiffResponse, error)
}

    DiffClient is the client API for Diff service.

    For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

    func NewDiffClient

    func NewDiffClient(cc *grpc.ClientConn) DiffClient

    type DiffRequest

    type DiffRequest struct {
    	// Left are the mounts which represent the older copy
    	// in which is the base of the computed changes.
    	Left []*types.Mount `protobuf:"bytes,1,rep,name=left,proto3" json:"left,omitempty"`
    	// Right are the mounts which represents the newer copy
    	// in which changes from the left were made into.
    	Right []*types.Mount `protobuf:"bytes,2,rep,name=right,proto3" json:"right,omitempty"`
    	// MediaType is the media type descriptor for the created diff
    	// object
    	MediaType string `protobuf:"bytes,3,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
    	// Ref identifies the pre-commit content store object. This
    	// reference can be used to get the status from the content store.
    	Ref string `protobuf:"bytes,4,opt,name=ref,proto3" json:"ref,omitempty"`
    	// Labels are the labels to apply to the generated content
    	// on content store commit.
    	Labels               map[string]string `` /* 153-byte string literal not displayed */
    	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    	XXX_unrecognized     []byte            `json:"-"`
    	XXX_sizecache        int32             `json:"-"`
    }

    func (*DiffRequest) Descriptor

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

    func (*DiffRequest) Marshal

    func (m *DiffRequest) Marshal() (dAtA []byte, err error)

    func (*DiffRequest) MarshalTo

    func (m *DiffRequest) MarshalTo(dAtA []byte) (int, error)

    func (*DiffRequest) MarshalToSizedBuffer

    func (m *DiffRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

    func (*DiffRequest) ProtoMessage

    func (*DiffRequest) ProtoMessage()

    func (*DiffRequest) Reset

    func (m *DiffRequest) Reset()

    func (*DiffRequest) Size

    func (m *DiffRequest) Size() (n int)

    func (*DiffRequest) String

    func (this *DiffRequest) String() string

    func (*DiffRequest) Unmarshal

    func (m *DiffRequest) Unmarshal(dAtA []byte) error

    func (*DiffRequest) XXX_DiscardUnknown

    func (m *DiffRequest) XXX_DiscardUnknown()

    func (*DiffRequest) XXX_Marshal

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

    func (*DiffRequest) XXX_Merge

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

    func (*DiffRequest) XXX_Size

    func (m *DiffRequest) XXX_Size() int

    func (*DiffRequest) XXX_Unmarshal

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

    type DiffResponse

    type DiffResponse struct {
    	// Diff is the descriptor of the diff which can be applied
    	Diff                 *types.Descriptor `protobuf:"bytes,3,opt,name=diff,proto3" json:"diff,omitempty"`
    	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    	XXX_unrecognized     []byte            `json:"-"`
    	XXX_sizecache        int32             `json:"-"`
    }

    func (*DiffResponse) Descriptor

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

    func (*DiffResponse) Marshal

    func (m *DiffResponse) Marshal() (dAtA []byte, err error)

    func (*DiffResponse) MarshalTo

    func (m *DiffResponse) MarshalTo(dAtA []byte) (int, error)

    func (*DiffResponse) MarshalToSizedBuffer

    func (m *DiffResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

    func (*DiffResponse) ProtoMessage

    func (*DiffResponse) ProtoMessage()

    func (*DiffResponse) Reset

    func (m *DiffResponse) Reset()

    func (*DiffResponse) Size

    func (m *DiffResponse) Size() (n int)

    func (*DiffResponse) String

    func (this *DiffResponse) String() string

    func (*DiffResponse) Unmarshal

    func (m *DiffResponse) Unmarshal(dAtA []byte) error

    func (*DiffResponse) XXX_DiscardUnknown

    func (m *DiffResponse) XXX_DiscardUnknown()

    func (*DiffResponse) XXX_Marshal

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

    func (*DiffResponse) XXX_Merge

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

    func (*DiffResponse) XXX_Size

    func (m *DiffResponse) XXX_Size() int

    func (*DiffResponse) XXX_Unmarshal

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

    type DiffServer

    type DiffServer interface {
    	// Apply applies the content associated with the provided digests onto
    	// the provided mounts. Archive content will be extracted and
    	// decompressed if necessary.
    	Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)
    	// Diff creates a diff between the given mounts and uploads the result
    	// to the content store.
    	Diff(context.Context, *DiffRequest) (*DiffResponse, error)
    }

      DiffServer is the server API for Diff service.

      type UnimplementedDiffServer

      type UnimplementedDiffServer struct {
      }

        UnimplementedDiffServer can be embedded to have forward compatible implementations.

        func (*UnimplementedDiffServer) Apply

        func (*UnimplementedDiffServer) Diff

        Source Files