remote

package
v1.1.1-0...-9418116 Latest Latest
Warning

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

 Go to latest Published: Jan 14, 2020 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"`
	MtimeUnix            int64      `protobuf:"varint,3,opt,name=MtimeUnix,proto3" json:"MtimeUnix,omitempty"`
	MtimeUnixNano        int64      `protobuf:"varint,4,opt,name=MtimeUnixNano,proto3" json:"MtimeUnixNano,omitempty"`
	Size                 int64      `protobuf:"varint,5,opt,name=Size,proto3" json:"Size,omitempty"`
	IsDir                bool       `protobuf:"varint,6,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) GetMtimeUnix 

func (m *Change) GetMtimeUnix() int64

func (*Change) GetMtimeUnixNano 

func (m *Change) GetMtimeUnixNano() 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 ChangeAmount 

type ChangeAmount struct {
	Amount               int64    `protobuf:"varint,1,opt,name=Amount,proto3" json:"Amount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChangeAmount) Descriptor 

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

func (*ChangeAmount) GetAmount 

func (m *ChangeAmount) GetAmount() int64

func (*ChangeAmount) ProtoMessage 

func (*ChangeAmount) ProtoMessage()

func (*ChangeAmount) Reset 

func (m *ChangeAmount) Reset()

func (*ChangeAmount) String 

func (m *ChangeAmount) String() string

func (*ChangeAmount) XXX_DiscardUnknown 

func (m *ChangeAmount) XXX_DiscardUnknown()

func (*ChangeAmount) XXX_Marshal 

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

func (*ChangeAmount) XXX_Merge 

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

func (*ChangeAmount) XXX_Size 

func (m *ChangeAmount) XXX_Size() int

func (*ChangeAmount) XXX_Unmarshal 

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

type ChangeChunk 

type ChangeChunk struct {
	Changes              []*Change `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ChangeChunk) Descriptor 

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

func (*ChangeChunk) GetChanges 

func (m *ChangeChunk) GetChanges() []*Change

func (*ChangeChunk) ProtoMessage 

func (*ChangeChunk) ProtoMessage()

func (*ChangeChunk) Reset 

func (m *ChangeChunk) Reset()

func (*ChangeChunk) String 

func (m *ChangeChunk) String() string

func (*ChangeChunk) XXX_DiscardUnknown 

func (m *ChangeChunk) XXX_DiscardUnknown()

func (*ChangeChunk) XXX_Marshal 

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

func (*ChangeChunk) XXX_Merge 

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

func (*ChangeChunk) XXX_Size 

func (m *ChangeChunk) XXX_Size() int

func (*ChangeChunk) XXX_Unmarshal 

func (m *ChangeChunk) 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 {
	Download(ctx context.Context, opts ...grpc.CallOption) (Downstream_DownloadClient, error)
	Changes(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Downstream_ChangesClient, error)
	ChangesCount(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ChangeAmount, 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 {
	Download(Downstream_DownloadServer) error
	Changes(*Empty, Downstream_ChangesServer) error
	ChangesCount(context.Context, *Empty) (*ChangeAmount, error)
}

DownstreamServer is the server API for Downstream service.

type Downstream_ChangesClient 

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

type Downstream_ChangesServer 

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

type Downstream_DownloadClient 

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

type Downstream_DownloadServer 

type Downstream_DownloadServer interface {
	Send(*Chunk) error
	Recv() (*Paths, 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 Paths 

type Paths 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 (*Paths) Descriptor 

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

func (*Paths) GetPaths 

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

func (*Paths) ProtoMessage 

func (*Paths) ProtoMessage()

func (*Paths) Reset 

func (m *Paths) Reset()

func (*Paths) String 

func (m *Paths) String() string

func (*Paths) XXX_DiscardUnknown 

func (m *Paths) XXX_DiscardUnknown()

func (*Paths) XXX_Marshal 

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

func (*Paths) XXX_Merge 

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

func (*Paths) XXX_Size 

func (m *Paths) XXX_Size() int

func (*Paths) XXX_Unmarshal 

func (m *Paths) 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(*Paths) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type Upstream_RemoveServer 

type Upstream_RemoveServer interface {
	SendAndClose(*Empty) error
	Recv() (*Paths, 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

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.