v1

package
v0.0.0-...-574a00b Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2019 License: Apache-2.0 Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBackup = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBackup   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Downstream_ChunkSize_name = map[int32]string{
	0: "FOUR_K",
	1: "ONE_K",
	3: "TWO_K",
	4: "EIGHT_K",
}
View Source 
var Downstream_ChunkSize_value = map[string]int32{
	"FOUR_K":  0,
	"ONE_K":   1,
	"TWO_K":   3,
	"EIGHT_K": 4,
}
View Source 
var Downstream_HashType_name = map[int32]string{
	0: "CRC32C",
}
View Source 
var Downstream_HashType_value = map[string]int32{
	"CRC32C": 0,
}
View Source 
var Downstream_Type_name = map[int32]string{
	0: "COMMITLOG",
	1: "INCREMENTAL",
	2: "SNAPSHOT",
}
View Source 
var Downstream_Type_value = map[string]int32{
	"COMMITLOG":   0,
	"INCREMENTAL": 1,
	"SNAPSHOT":    2,
}

Functions

func RegisterBackupServiceServer 

func RegisterBackupServiceServer(s *grpc.Server, srv BackupServiceServer)

Types

type BackupServiceClient 

type BackupServiceClient interface {
	StreamFrom(ctx context.Context, in *Downstream, opts ...grpc.CallOption) (BackupService_StreamFromClient, error)
	StreamTo(ctx context.Context, opts ...grpc.CallOption) (BackupService_StreamToClient, error)
	DeleteCommitLog(ctx context.Context, opts ...grpc.CallOption) (BackupService_DeleteCommitLogClient, error)
	DeleteIncremental(ctx context.Context, opts ...grpc.CallOption) (BackupService_DeleteIncrementalClient, error)
}

BackupServiceClient is the client API for BackupService service.

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

func NewBackupServiceClient 

func NewBackupServiceClient(cc *grpc.ClientConn) BackupServiceClient

type BackupServiceServer 

type BackupServiceServer interface {
	StreamFrom(*Downstream, BackupService_StreamFromServer) error
	StreamTo(BackupService_StreamToServer) error
	DeleteCommitLog(BackupService_DeleteCommitLogServer) error
	DeleteIncremental(BackupService_DeleteIncrementalServer) error
}

BackupServiceServer is the server API for BackupService service.

type BackupService_DeleteCommitLogClient 

type BackupService_DeleteCommitLogClient interface {
	Send(*DeleteRequest) error
	Recv() (*DeleteResponse, error)
	grpc.ClientStream
}

type BackupService_DeleteCommitLogServer 

type BackupService_DeleteCommitLogServer interface {
	Send(*DeleteResponse) error
	Recv() (*DeleteRequest, error)
	grpc.ServerStream
}

type BackupService_DeleteIncrementalClient 

type BackupService_DeleteIncrementalClient interface {
	Send(*DeleteRequest) error
	Recv() (*DeleteResponse, error)
	grpc.ClientStream
}

type BackupService_DeleteIncrementalServer 

type BackupService_DeleteIncrementalServer interface {
	Send(*DeleteResponse) error
	Recv() (*DeleteRequest, error)
	grpc.ServerStream
}

type BackupService_StreamFromClient 

type BackupService_StreamFromClient interface {
	Recv() (*Upstream, error)
	grpc.ClientStream
}

type BackupService_StreamFromServer 

type BackupService_StreamFromServer interface {
	Send(*Upstream) error
	grpc.ServerStream
}

type BackupService_StreamToClient 

type BackupService_StreamToClient interface {
	Send(*Restore) error
	Recv() (*RestoreResponse, error)
	grpc.ClientStream
}

type BackupService_StreamToServer 

type BackupService_StreamToServer interface {
	Send(*RestoreResponse) error
	Recv() (*Restore, error)
	grpc.ServerStream
}

type DeleteRequest 

type DeleteRequest struct {
	File string `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetFile 

func (m *DeleteRequest) GetFile() string

func (*DeleteRequest) Marshal 

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

func (*DeleteRequest) MarshalTo 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

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

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

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

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

func (dst *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DeleteResponse 

type DeleteResponse struct {
	Fail    bool   `protobuf:"varint,1,opt,name=fail,proto3" json:"fail,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) GetFail 

func (m *DeleteResponse) GetFail() bool

func (*DeleteResponse) GetMessage 

func (m *DeleteResponse) GetMessage() string

func (*DeleteResponse) Marshal 

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

func (*DeleteResponse) MarshalTo 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

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

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

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

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

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

func (*DeleteResponse) XXX_Merge 

func (dst *DeleteResponse) XXX_Merge(src proto.Message)

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

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

type Downstream 

type Downstream struct {
	Type      Downstream_Type      `protobuf:"varint,1,opt,name=type,proto3,enum=linuxuser586.cassandra.backup.v1.Downstream_Type" json:"type,omitempty"`
	ChunkSize Downstream_ChunkSize `` /* 148-byte string literal not displayed */
	HashType  Downstream_HashType  `` /* 144-byte string literal not displayed */
	Resume    *Downstream_Resume   `protobuf:"bytes,4,opt,name=resume" json:"resume,omitempty"`
}

func (*Downstream) Descriptor 

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

func (*Downstream) GetChunkSize 

func (m *Downstream) GetChunkSize() Downstream_ChunkSize

func (*Downstream) GetHashType 

func (m *Downstream) GetHashType() Downstream_HashType

func (*Downstream) GetResume 

func (m *Downstream) GetResume() *Downstream_Resume

func (*Downstream) GetType 

func (m *Downstream) GetType() Downstream_Type

func (*Downstream) Marshal 

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

func (*Downstream) MarshalTo 

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

func (*Downstream) ProtoMessage 

func (*Downstream) ProtoMessage()

func (*Downstream) Reset 

func (m *Downstream) Reset()

func (*Downstream) Size 

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

func (*Downstream) String 

func (m *Downstream) String() string

func (*Downstream) Unmarshal 

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

func (*Downstream) XXX_DiscardUnknown 

func (m *Downstream) XXX_DiscardUnknown()

func (*Downstream) XXX_Marshal 

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

func (*Downstream) XXX_Merge 

func (dst *Downstream) XXX_Merge(src proto.Message)

func (*Downstream) XXX_Size 

func (m *Downstream) XXX_Size() int

func (*Downstream) XXX_Unmarshal 

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

type Downstream_ChunkSize 

type Downstream_ChunkSize int32
const (
	Downstream_FOUR_K  Downstream_ChunkSize = 0
	Downstream_ONE_K   Downstream_ChunkSize = 1
	Downstream_TWO_K   Downstream_ChunkSize = 3
	Downstream_EIGHT_K Downstream_ChunkSize = 4
)

func (Downstream_ChunkSize) EnumDescriptor 

func (Downstream_ChunkSize) EnumDescriptor() ([]byte, []int)

func (Downstream_ChunkSize) String 

func (x Downstream_ChunkSize) String() string

type Downstream_HashType 

type Downstream_HashType int32
const (
	Downstream_CRC32C Downstream_HashType = 0
)

func (Downstream_HashType) EnumDescriptor 

func (Downstream_HashType) EnumDescriptor() ([]byte, []int)

func (Downstream_HashType) String 

func (x Downstream_HashType) String() string

type Downstream_Resume 

type Downstream_Resume struct {
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Position int64  `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	Path     string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
}

func (*Downstream_Resume) Descriptor 

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

func (*Downstream_Resume) GetFileName 

func (m *Downstream_Resume) GetFileName() string

func (*Downstream_Resume) GetPath 

func (m *Downstream_Resume) GetPath() string

func (*Downstream_Resume) GetPosition 

func (m *Downstream_Resume) GetPosition() int64

func (*Downstream_Resume) Marshal 

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

func (*Downstream_Resume) MarshalTo 

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

func (*Downstream_Resume) ProtoMessage 

func (*Downstream_Resume) ProtoMessage()

func (*Downstream_Resume) Reset 

func (m *Downstream_Resume) Reset()

func (*Downstream_Resume) Size 

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

func (*Downstream_Resume) String 

func (m *Downstream_Resume) String() string

func (*Downstream_Resume) Unmarshal 

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

func (*Downstream_Resume) XXX_DiscardUnknown 

func (m *Downstream_Resume) XXX_DiscardUnknown()

func (*Downstream_Resume) XXX_Marshal 

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

func (*Downstream_Resume) XXX_Merge 

func (dst *Downstream_Resume) XXX_Merge(src proto.Message)

func (*Downstream_Resume) XXX_Size 

func (m *Downstream_Resume) XXX_Size() int

func (*Downstream_Resume) XXX_Unmarshal 

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

type Downstream_Type 

type Downstream_Type int32
const (
	Downstream_COMMITLOG   Downstream_Type = 0
	Downstream_INCREMENTAL Downstream_Type = 1
	Downstream_SNAPSHOT    Downstream_Type = 2
)

func (Downstream_Type) EnumDescriptor 

func (Downstream_Type) EnumDescriptor() ([]byte, []int)

func (Downstream_Type) String 

func (x Downstream_Type) String() string

type Restore 

type Restore struct {
	// Types that are valid to be assigned to Payload:
	//	*Restore_Downstream
	//	*Restore_Upstream
	Payload isRestore_Payload `protobuf_oneof:"payload"`
}

func (*Restore) Descriptor 

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

func (*Restore) GetDownstream 

func (m *Restore) GetDownstream() *Downstream

func (*Restore) GetPayload 

func (m *Restore) GetPayload() isRestore_Payload

func (*Restore) GetUpstream 

func (m *Restore) GetUpstream() *Upstream

func (*Restore) Marshal 

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

func (*Restore) MarshalTo 

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

func (*Restore) ProtoMessage 

func (*Restore) ProtoMessage()

func (*Restore) Reset 

func (m *Restore) Reset()

func (*Restore) Size 

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

func (*Restore) String 

func (m *Restore) String() string

func (*Restore) Unmarshal 

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

func (*Restore) XXX_DiscardUnknown 

func (m *Restore) XXX_DiscardUnknown()

func (*Restore) XXX_Marshal 

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

func (*Restore) XXX_Merge 

func (dst *Restore) XXX_Merge(src proto.Message)

func (*Restore) XXX_OneofFuncs 

func (*Restore) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Restore) XXX_Size 

func (m *Restore) XXX_Size() int

func (*Restore) XXX_Unmarshal 

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

type RestoreResponse 

type RestoreResponse struct {
	Fail    bool   `protobuf:"varint,1,opt,name=fail,proto3" json:"fail,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*RestoreResponse) Descriptor 

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

func (*RestoreResponse) GetFail 

func (m *RestoreResponse) GetFail() bool

func (*RestoreResponse) GetMessage 

func (m *RestoreResponse) GetMessage() string

func (*RestoreResponse) Marshal 

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

func (*RestoreResponse) MarshalTo 

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

func (*RestoreResponse) ProtoMessage 

func (*RestoreResponse) ProtoMessage()

func (*RestoreResponse) Reset 

func (m *RestoreResponse) Reset()

func (*RestoreResponse) Size 

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

func (*RestoreResponse) String 

func (m *RestoreResponse) String() string

func (*RestoreResponse) Unmarshal 

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

func (*RestoreResponse) XXX_DiscardUnknown 

func (m *RestoreResponse) XXX_DiscardUnknown()

func (*RestoreResponse) XXX_Marshal 

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

func (*RestoreResponse) XXX_Merge 

func (dst *RestoreResponse) XXX_Merge(src proto.Message)

func (*RestoreResponse) XXX_Size 

func (m *RestoreResponse) XXX_Size() int

func (*RestoreResponse) XXX_Unmarshal 

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

type Restore_Downstream 

type Restore_Downstream struct {
	Downstream *Downstream `protobuf:"bytes,1,opt,name=downstream,oneof"`
}

func (*Restore_Downstream) MarshalTo 

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

func (*Restore_Downstream) Size 

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

type Restore_Upstream 

type Restore_Upstream struct {
	Upstream *Upstream `protobuf:"bytes,2,opt,name=upstream,oneof"`
}

func (*Restore_Upstream) MarshalTo 

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

func (*Restore_Upstream) Size 

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

type Upstream 

type Upstream struct {
	// Types that are valid to be assigned to Payload:
	//	*Upstream_Meta_
	//	*Upstream_Chunk_
	Payload isUpstream_Payload `protobuf_oneof:"payload"`
}

func (*Upstream) Descriptor 

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

func (*Upstream) GetChunk 

func (m *Upstream) GetChunk() *Upstream_Chunk

func (*Upstream) GetMeta 

func (m *Upstream) GetMeta() *Upstream_Meta

func (*Upstream) GetPayload 

func (m *Upstream) GetPayload() isUpstream_Payload

func (*Upstream) Marshal 

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

func (*Upstream) MarshalTo 

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

func (*Upstream) ProtoMessage 

func (*Upstream) ProtoMessage()

func (*Upstream) Reset 

func (m *Upstream) Reset()

func (*Upstream) Size 

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

func (*Upstream) String 

func (m *Upstream) String() string

func (*Upstream) Unmarshal 

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

func (*Upstream) XXX_DiscardUnknown 

func (m *Upstream) XXX_DiscardUnknown()

func (*Upstream) XXX_Marshal 

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

func (*Upstream) XXX_Merge 

func (dst *Upstream) XXX_Merge(src proto.Message)

func (*Upstream) XXX_OneofFuncs 

func (*Upstream) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Upstream) XXX_Size 

func (m *Upstream) XXX_Size() int

func (*Upstream) XXX_Unmarshal 

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

type Upstream_Chunk 

type Upstream_Chunk struct {
	Position int64  `protobuf:"varint,1,opt,name=position,proto3" json:"position,omitempty"`
	Data     []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Eof      bool   `protobuf:"varint,3,opt,name=eof,proto3" json:"eof,omitempty"`
}

func (*Upstream_Chunk) Descriptor 

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

func (*Upstream_Chunk) GetData 

func (m *Upstream_Chunk) GetData() []byte

func (*Upstream_Chunk) GetEof 

func (m *Upstream_Chunk) GetEof() bool

func (*Upstream_Chunk) GetPosition 

func (m *Upstream_Chunk) GetPosition() int64

func (*Upstream_Chunk) Marshal 

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

func (*Upstream_Chunk) MarshalTo 

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

func (*Upstream_Chunk) ProtoMessage 

func (*Upstream_Chunk) ProtoMessage()

func (*Upstream_Chunk) Reset 

func (m *Upstream_Chunk) Reset()

func (*Upstream_Chunk) Size 

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

func (*Upstream_Chunk) String 

func (m *Upstream_Chunk) String() string

func (*Upstream_Chunk) Unmarshal 

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

func (*Upstream_Chunk) XXX_DiscardUnknown 

func (m *Upstream_Chunk) XXX_DiscardUnknown()

func (*Upstream_Chunk) XXX_Marshal 

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

func (*Upstream_Chunk) XXX_Merge 

func (dst *Upstream_Chunk) XXX_Merge(src proto.Message)

func (*Upstream_Chunk) XXX_Size 

func (m *Upstream_Chunk) XXX_Size() int

func (*Upstream_Chunk) XXX_Unmarshal 

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

type Upstream_Chunk_ 

type Upstream_Chunk_ struct {
	Chunk *Upstream_Chunk `protobuf:"bytes,2,opt,name=chunk,oneof"`
}

func (*Upstream_Chunk_) MarshalTo 

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

func (*Upstream_Chunk_) Size 

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

type Upstream_Meta 

type Upstream_Meta struct {
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	FileSize int64  `protobuf:"varint,2,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	Hash     string `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
	Path     string `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
}

func (*Upstream_Meta) Descriptor 

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

func (*Upstream_Meta) GetFileName 

func (m *Upstream_Meta) GetFileName() string

func (*Upstream_Meta) GetFileSize 

func (m *Upstream_Meta) GetFileSize() int64

func (*Upstream_Meta) GetHash 

func (m *Upstream_Meta) GetHash() string

func (*Upstream_Meta) GetPath 

func (m *Upstream_Meta) GetPath() string

func (*Upstream_Meta) Marshal 

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

func (*Upstream_Meta) MarshalTo 

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

func (*Upstream_Meta) ProtoMessage 

func (*Upstream_Meta) ProtoMessage()

func (*Upstream_Meta) Reset 

func (m *Upstream_Meta) Reset()

func (*Upstream_Meta) Size 

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

func (*Upstream_Meta) String 

func (m *Upstream_Meta) String() string

func (*Upstream_Meta) Unmarshal 

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

func (*Upstream_Meta) XXX_DiscardUnknown 

func (m *Upstream_Meta) XXX_DiscardUnknown()

func (*Upstream_Meta) XXX_Marshal 

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

func (*Upstream_Meta) XXX_Merge 

func (dst *Upstream_Meta) XXX_Merge(src proto.Message)

func (*Upstream_Meta) XXX_Size 

func (m *Upstream_Meta) XXX_Size() int

func (*Upstream_Meta) XXX_Unmarshal 

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

type Upstream_Meta_ 

type Upstream_Meta_ struct {
	Meta *Upstream_Meta `protobuf:"bytes,1,opt,name=meta,oneof"`
}

func (*Upstream_Meta_) MarshalTo 

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

func (*Upstream_Meta_) Size 

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

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

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.