diff

package
v1.3.0-k3s.5-zfs Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 2, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

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")
)

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) 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) 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) 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) 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.