proto

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files:

cas.proto

It has these top-level messages:

GetRequest
GetReply
PutRequest
PutReply
RemoveRequest
RemoveReply
StatRequest
StatReply
WalkRequest
WalkReply

Index

• func RegisterCASServer(s *grpc.Server, srv CASServer)
• type CASClient
  • func NewCASClient(cc *grpc.ClientConn) CASClient
• type CASServer
• type CAS_WalkClient
• type CAS_WalkServer
• type GetReply
  • func (*GetReply) ProtoMessage()
  • func (m *GetReply) Reset()
  • func (m *GetReply) String() string
• type GetRequest
  • func (*GetRequest) ProtoMessage()
  • func (m *GetRequest) Reset()
  • func (m *GetRequest) String() string
• type PutReply
  • func (*PutReply) ProtoMessage()
  • func (m *PutReply) Reset()
  • func (m *PutReply) String() string
• type PutRequest
  • func (*PutRequest) ProtoMessage()
  • func (m *PutRequest) Reset()
  • func (m *PutRequest) String() string
• type RemoveReply
  • func (*RemoveReply) ProtoMessage()
  • func (m *RemoveReply) Reset()
  • func (m *RemoveReply) String() string
• type RemoveRequest
  • func (*RemoveRequest) ProtoMessage()
  • func (m *RemoveRequest) Reset()
  • func (m *RemoveRequest) String() string
• type StatReply
  • func (*StatReply) ProtoMessage()
  • func (m *StatReply) Reset()
  • func (m *StatReply) String() string
• type StatRequest
  • func (*StatRequest) ProtoMessage()
  • func (m *StatRequest) Reset()
  • func (m *StatRequest) String() string
• type WalkReply
  • func (*WalkReply) ProtoMessage()
  • func (m *WalkReply) Reset()
  • func (m *WalkReply) String() string
• type WalkRequest
  • func (*WalkRequest) ProtoMessage()
  • func (m *WalkRequest) Reset()
  • func (m *WalkRequest) String() string

Functions

func RegisterCASServer

func RegisterCASServer(s *grpc.Server, srv CASServer)

Types

type CASClient

type CASClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutReply, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveReply, error)
	Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatReply, error)
	Walk(ctx context.Context, in *WalkRequest, opts ...grpc.CallOption) (CAS_WalkClient, error)
}

func NewCASClient

func NewCASClient(cc *grpc.ClientConn) CASClient

type CASServer

type CASServer interface {
	Get(context.Context, *GetRequest) (*GetReply, error)
	Put(context.Context, *PutRequest) (*PutReply, error)
	Remove(context.Context, *RemoveRequest) (*RemoveReply, error)
	Stat(context.Context, *StatRequest) (*StatReply, error)
	Walk(*WalkRequest, CAS_WalkServer) error
}

type CAS_WalkClient

type CAS_WalkClient interface {
	Recv() (*WalkReply, error)
	grpc.ClientStream
}

type CAS_WalkServer

type CAS_WalkServer interface {
	Send(*WalkReply) error
	grpc.ServerStream
}

type GetReply

type GetReply struct {
	Block []byte `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	Found bool   `protobuf:"varint,2,opt,name=found" json:"found,omitempty"`
}

func (*GetReply) ProtoMessage

func (*GetReply) ProtoMessage()

func (*GetReply) Reset

func (m *GetReply) Reset()

func (*GetReply) String

func (m *GetReply) String() string

type GetRequest

type GetRequest struct {
	Addr    string `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
	NoBlock bool   `protobuf:"varint,2,opt,name=no_block" json:"no_block,omitempty"`
}

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset

func (m *GetRequest) Reset()

func (*GetRequest) String

func (m *GetRequest) String() string

type PutReply

type PutReply struct {
	Addr     string `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
	Inserted bool   `protobuf:"varint,2,opt,name=inserted" json:"inserted,omitempty"`
}

func (*PutReply) ProtoMessage

func (*PutReply) ProtoMessage()

func (*PutReply) Reset

func (m *PutReply) Reset()

func (*PutReply) String

func (m *PutReply) String() string

type PutRequest

type PutRequest struct {
	Addr  string `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
	Block []byte `protobuf:"bytes,2,opt,name=block,proto3" json:"block,omitempty"`
}

func (*PutRequest) ProtoMessage

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset

func (m *PutRequest) Reset()

func (*PutRequest) String

func (m *PutRequest) String() string

type RemoveReply

type RemoveReply struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted" json:"deleted,omitempty"`
}

func (*RemoveReply) ProtoMessage

func (*RemoveReply) ProtoMessage()

func (*RemoveReply) Reset

func (m *RemoveReply) Reset()

func (*RemoveReply) String

func (m *RemoveReply) String() string

type RemoveRequest

type RemoveRequest struct {
	Addr  string `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
	Shred bool   `protobuf:"varint,2,opt,name=shred" json:"shred,omitempty"`
}

func (*RemoveRequest) ProtoMessage

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset

func (m *RemoveRequest) Reset()

func (*RemoveRequest) String

func (m *RemoveRequest) String() string

type StatReply

type StatReply struct {
	BlocksUsed int64 `protobuf:"varint,1,opt,name=blocks_used" json:"blocks_used,omitempty"`
	BlocksFree int64 `protobuf:"varint,2,opt,name=blocks_free" json:"blocks_free,omitempty"`
}

func (*StatReply) ProtoMessage

func (*StatReply) ProtoMessage()

func (*StatReply) Reset

func (m *StatReply) Reset()

func (*StatReply) String

func (m *StatReply) String() string

type StatRequest

type StatRequest struct {
}

func (*StatRequest) ProtoMessage

func (*StatRequest) ProtoMessage()

func (*StatRequest) Reset

func (m *StatRequest) Reset()

func (*StatRequest) String

func (m *StatRequest) String() string

type WalkReply

type WalkReply struct {
	Addr  string `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
	Block []byte `protobuf:"bytes,2,opt,name=block,proto3" json:"block,omitempty"`
}

func (*WalkReply) ProtoMessage

func (*WalkReply) ProtoMessage()

func (*WalkReply) Reset

func (m *WalkReply) Reset()

func (*WalkReply) String

func (m *WalkReply) String() string

type WalkRequest

type WalkRequest struct {
	WantBlocks bool   `protobuf:"varint,1,opt,name=want_blocks" json:"want_blocks,omitempty"`
	Regexp     string `protobuf:"bytes,2,opt,name=regexp" json:"regexp,omitempty"`
}

func (*WalkRequest) ProtoMessage

func (*WalkRequest) ProtoMessage()

func (*WalkRequest) Reset

func (m *WalkRequest) Reset()

func (*WalkRequest) String

func (m *WalkRequest) String() string