remote

package
v0.0.0-...-89f11bb Latest Latest
Warning

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

Go to latest
Published: May 23, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ChangeType_name = map[int32]string{
	0: "CHANGE",
	1: "DELETE",
}
View Source
var ChangeType_value = map[string]int32{
	"CHANGE": 0,
	"DELETE": 1,
}

Functions

func RegisterDownstreamServer

func RegisterDownstreamServer(s *grpc.Server, srv DownstreamServer)

func RegisterUpstreamServer

func RegisterUpstreamServer(s *grpc.Server, srv UpstreamServer)

Types

type Change

type Change struct {
	ChangeType           ChangeType `protobuf:"varint,1,opt,name=ChangeType,proto3,enum=remote.ChangeType" json:"ChangeType,omitempty"`
	Path                 string     `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty"`
	Mtime                int64      `protobuf:"varint,3,opt,name=Mtime,proto3" json:"Mtime,omitempty"`
	Size                 int64      `protobuf:"varint,4,opt,name=Size,proto3" json:"Size,omitempty"`
	IsDir                bool       `protobuf:"varint,5,opt,name=IsDir,proto3" json:"IsDir,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Change) Descriptor

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

func (*Change) GetChangeType

func (m *Change) GetChangeType() ChangeType

func (*Change) GetIsDir

func (m *Change) GetIsDir() bool

func (*Change) GetMtime

func (m *Change) GetMtime() int64

func (*Change) GetPath

func (m *Change) GetPath() string

func (*Change) GetSize

func (m *Change) GetSize() int64

func (*Change) ProtoMessage

func (*Change) ProtoMessage()

func (*Change) Reset

func (m *Change) Reset()

func (*Change) String

func (m *Change) String() string

func (*Change) XXX_DiscardUnknown

func (m *Change) XXX_DiscardUnknown()

func (*Change) XXX_Marshal

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

func (*Change) XXX_Merge

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

func (*Change) XXX_Size

func (m *Change) XXX_Size() int

func (*Change) XXX_Unmarshal

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

type ChangeType

type ChangeType int32
const (
	ChangeType_CHANGE ChangeType = 0
	ChangeType_DELETE ChangeType = 1
)

func (ChangeType) EnumDescriptor

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

func (ChangeType) String

func (x ChangeType) String() string

type Chunk

type Chunk struct {
	Content              []byte   `protobuf:"bytes,1,opt,name=Content,proto3" json:"Content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Chunk) Descriptor

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

func (*Chunk) GetContent

func (m *Chunk) GetContent() []byte

func (*Chunk) ProtoMessage

func (*Chunk) ProtoMessage()

func (*Chunk) Reset

func (m *Chunk) Reset()

func (*Chunk) String

func (m *Chunk) String() string

func (*Chunk) XXX_DiscardUnknown

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal

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

func (*Chunk) XXX_Merge

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

func (*Chunk) XXX_Size

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal

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

type DownstreamClient

type DownstreamClient interface {
	Compress(ctx context.Context, opts ...grpc.CallOption) (Downstream_CompressClient, error)
	Download(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Downstream_DownloadClient, error)
	Changes(ctx context.Context, in *Excluded, opts ...grpc.CallOption) (Downstream_ChangesClient, error)
}

DownstreamClient is the client API for Downstream service.

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

func NewDownstreamClient

func NewDownstreamClient(cc *grpc.ClientConn) DownstreamClient

type DownstreamServer

type DownstreamServer interface {
	Compress(Downstream_CompressServer) error
	Download(*Empty, Downstream_DownloadServer) error
	Changes(*Excluded, Downstream_ChangesServer) error
}

DownstreamServer is the server API for Downstream service.

type Downstream_ChangesClient

type Downstream_ChangesClient interface {
	Recv() (*Change, error)
	grpc.ClientStream
}

type Downstream_ChangesServer

type Downstream_ChangesServer interface {
	Send(*Change) error
	grpc.ServerStream
}

type Downstream_CompressClient

type Downstream_CompressClient interface {
	Send(*Path) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type Downstream_CompressServer

type Downstream_CompressServer interface {
	SendAndClose(*Empty) error
	Recv() (*Path, error)
	grpc.ServerStream
}

type Downstream_DownloadClient

type Downstream_DownloadClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type Downstream_DownloadServer

type Downstream_DownloadServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type Empty

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor

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

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) String

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal

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

func (*Empty) XXX_Merge

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

func (*Empty) XXX_Size

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal

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

type Excluded

type Excluded struct {
	Paths                []string `protobuf:"bytes,1,rep,name=Paths,proto3" json:"Paths,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Excluded) Descriptor

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

func (*Excluded) GetPaths

func (m *Excluded) GetPaths() []string

func (*Excluded) ProtoMessage

func (*Excluded) ProtoMessage()

func (*Excluded) Reset

func (m *Excluded) Reset()

func (*Excluded) String

func (m *Excluded) String() string

func (*Excluded) XXX_DiscardUnknown

func (m *Excluded) XXX_DiscardUnknown()

func (*Excluded) XXX_Marshal

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

func (*Excluded) XXX_Merge

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

func (*Excluded) XXX_Size

func (m *Excluded) XXX_Size() int

func (*Excluded) XXX_Unmarshal

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

type Path

type Path struct {
	Path                 string   `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Path) Descriptor

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

func (*Path) GetPath

func (m *Path) GetPath() string

func (*Path) ProtoMessage

func (*Path) ProtoMessage()

func (*Path) Reset

func (m *Path) Reset()

func (*Path) String

func (m *Path) String() string

func (*Path) XXX_DiscardUnknown

func (m *Path) XXX_DiscardUnknown()

func (*Path) XXX_Marshal

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

func (*Path) XXX_Merge

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

func (*Path) XXX_Size

func (m *Path) XXX_Size() int

func (*Path) XXX_Unmarshal

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

type UpstreamClient

type UpstreamClient interface {
	Upload(ctx context.Context, opts ...grpc.CallOption) (Upstream_UploadClient, error)
	Remove(ctx context.Context, opts ...grpc.CallOption) (Upstream_RemoveClient, error)
}

UpstreamClient is the client API for Upstream service.

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

func NewUpstreamClient

func NewUpstreamClient(cc *grpc.ClientConn) UpstreamClient

type UpstreamServer

type UpstreamServer interface {
	Upload(Upstream_UploadServer) error
	Remove(Upstream_RemoveServer) error
}

UpstreamServer is the server API for Upstream service.

type Upstream_RemoveClient

type Upstream_RemoveClient interface {
	Send(*Path) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type Upstream_RemoveServer

type Upstream_RemoveServer interface {
	SendAndClose(*Empty) error
	Recv() (*Path, error)
	grpc.ServerStream
}

type Upstream_UploadClient

type Upstream_UploadClient interface {
	Send(*Chunk) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type Upstream_UploadServer

type Upstream_UploadServer interface {
	SendAndClose(*Empty) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

type Watch

type Watch struct {
	Path                 string   `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	Exclude              []string `protobuf:"bytes,2,rep,name=Exclude,proto3" json:"Exclude,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Watch) Descriptor

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

func (*Watch) GetExclude

func (m *Watch) GetExclude() []string

func (*Watch) GetPath

func (m *Watch) GetPath() string

func (*Watch) ProtoMessage

func (*Watch) ProtoMessage()

func (*Watch) Reset

func (m *Watch) Reset()

func (*Watch) String

func (m *Watch) String() string

func (*Watch) XXX_DiscardUnknown

func (m *Watch) XXX_DiscardUnknown()

func (*Watch) XXX_Marshal

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

func (*Watch) XXX_Merge

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

func (*Watch) XXX_Size

func (m *Watch) XXX_Size() int

func (*Watch) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL