Documentation ¶
Overview ¶
Package propagator is a generated protocol buffer package.
It is generated from these files:
propagator.proto
It has these top-level messages:
Void PutReq GetReq RmReq MvReq Record
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterPropServer ¶
func RegisterPropServer(s *grpc.Server, srv PropServer)
Types ¶
type GetReq ¶
type GetReq struct { AccessToken string `protobuf:"bytes,1,opt,name=access_token" json:"access_token,omitempty"` Path string `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"` ForceCreation bool `protobuf:"varint,3,opt,name=force_creation" json:"force_creation,omitempty"` }
func (*GetReq) ProtoMessage ¶
func (*GetReq) ProtoMessage()
type MvReq ¶
type MvReq struct { AccessToken string `protobuf:"bytes,1,opt,name=access_token" json:"access_token,omitempty"` Src string `protobuf:"bytes,2,opt,name=src" json:"src,omitempty"` Dst string `protobuf:"bytes,3,opt,name=dst" json:"dst,omitempty"` }
func (*MvReq) ProtoMessage ¶
func (*MvReq) ProtoMessage()
type PropClient ¶
type PropClient interface { Put(ctx context.Context, in *PutReq, opts ...grpc.CallOption) (*Void, error) Get(ctx context.Context, in *GetReq, opts ...grpc.CallOption) (*Record, error) // rpc Cp(CpReq) returns (Void) {} Mv(ctx context.Context, in *MvReq, opts ...grpc.CallOption) (*Void, error) Rm(ctx context.Context, in *RmReq, opts ...grpc.CallOption) (*Void, error) }
func NewPropClient ¶
func NewPropClient(cc *grpc.ClientConn) PropClient
type PropServer ¶
type PutReq ¶
type PutReq struct { AccessToken string `protobuf:"bytes,1,opt,name=access_token" json:"access_token,omitempty"` Path string `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"` Checksum string `protobuf:"bytes,3,opt,name=checksum" json:"checksum,omitempty"` }
func (*PutReq) ProtoMessage ¶
func (*PutReq) ProtoMessage()
type Record ¶
type Record struct { Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"` Path string `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"` Checksum string `protobuf:"bytes,3,opt,name=checksum" json:"checksum,omitempty"` Modified uint32 `protobuf:"varint,4,opt,name=modified" json:"modified,omitempty"` Etag string `protobuf:"bytes,5,opt,name=etag" json:"etag,omitempty"` }
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.