rpc

package
v0.0.0-...-4e84fbd Latest Latest
Warning

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

 Go to latest Published: Jul 21, 2016 License: BSD-3-Clause Imports: 9 Imported by: 1

Documentation

Overview

Package pyxis_rpc is a generated protocol buffer package.

It is generated from these files: 

rpc.proto

It has these top-level messages: 

Error
WatchEvent
RegisterRequest
UnRegisterRequest
PingRequest
CreateRequest
DeleteRequest
StatRequest
ReadRequest
WriteRequest
WatchRequest
Request
Response

Index

Constants

This section is empty.

Variables

View Source 
var ErrorType_name = map[int32]string{
	0: "kNone",
	1: "kNotLeader",
	2: "kNotFound",
	4: "kSessionExpired",
	5: "kInvalidArgument",
	6: "kAgain",
	7: "kInternal",
	8: "kExist",
}
View Source 
var ErrorType_value = map[string]int32{
	"kNone":            0,
	"kNotLeader":       1,
	"kNotFound":        2,
	"kSessionExpired":  4,
	"kInvalidArgument": 5,
	"kAgain":           6,
	"kInternal":        7,
	"kExist":           8,
}
View Source 
var (
	RPC_MAGIC = [4]byte{'p', 'y', 'x', 'i'}
)

Functions

func Dial 

func Dial(addr string) (*rpc.Client, error)

func EncodePacket 

func EncodePacket(w io.Writer, payload []byte) error

4bytes total size 4bytes magic payload 4bytes adler32 checksum

func NewClient 

func NewClient(conn io.ReadWriteCloser) *rpc.Client

func NewClientCodec 

func NewClientCodec(rwc io.ReadWriteCloser) rpc.ClientCodec

Types

type CreateRequest 

type CreateRequest struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	Flags            *int32  `protobuf:"varint,2,req,name=flags" json:"flags,omitempty"`
	Data             []byte  `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateRequest) GetData 

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

func (*CreateRequest) GetFlags 

func (m *CreateRequest) GetFlags() int32

func (*CreateRequest) GetPath 

func (m *CreateRequest) GetPath() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

type DeleteRequest 

type DeleteRequest struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteRequest) GetPath 

func (m *DeleteRequest) GetPath() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

type Error 

type Error struct {
	Type             *ErrorType `protobuf:"varint,1,req,name=type,enum=pyxis.rpc.ErrorType" json:"type,omitempty"`
	Data             []byte     `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*Error) GetData 

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

func (*Error) GetType 

func (m *Error) GetType() ErrorType

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

type ErrorType 

type ErrorType int32
const (
	ErrorType_kNone            ErrorType = 0
	ErrorType_kNotLeader       ErrorType = 1
	ErrorType_kNotFound        ErrorType = 2
	ErrorType_kSessionExpired  ErrorType = 4
	ErrorType_kInvalidArgument ErrorType = 5
	ErrorType_kAgain           ErrorType = 6
	ErrorType_kInternal        ErrorType = 7
	ErrorType_kExist           ErrorType = 8
)

func (ErrorType) Enum 

func (x ErrorType) Enum() *ErrorType

func (ErrorType) String 

func (x ErrorType) String() string

func (*ErrorType) UnmarshalJSON 

func (x *ErrorType) UnmarshalJSON(data []byte) error

type Packet 

type Packet struct {
	TotalSize uint32
	Magic     [4]byte
	Payload   []byte
	Checksum  uint32
}

type PingRequest 

type PingRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset 

func (m *PingRequest) Reset()

func (*PingRequest) String 

func (m *PingRequest) String() string

type ReadRequest 

type ReadRequest struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ReadRequest) GetPath 

func (m *ReadRequest) GetPath() string

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) String 

func (m *ReadRequest) String() string

type RegisterRequest 

type RegisterRequest struct {
	Timeout          *int32 `protobuf:"varint,1,opt,name=timeout" json:"timeout,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RegisterRequest) GetTimeout 

func (m *RegisterRequest) GetTimeout() int32

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

type Request 

type Request struct {
	Sid              *uint64            `protobuf:"varint,1,opt,name=sid" json:"sid,omitempty"`
	Xid              *uint64            `protobuf:"varint,2,opt,name=xid" json:"xid,omitempty"`
	Register         *RegisterRequest   `protobuf:"bytes,5,opt,name=register" json:"register,omitempty"`
	Unregister       *UnRegisterRequest `protobuf:"bytes,6,opt,name=unregister" json:"unregister,omitempty"`
	Ping             *PingRequest       `protobuf:"bytes,7,opt,name=ping" json:"ping,omitempty"`
	Create           *CreateRequest     `protobuf:"bytes,8,opt,name=create" json:"create,omitempty"`
	Delete           *DeleteRequest     `protobuf:"bytes,9,opt,name=delete" json:"delete,omitempty"`
	Write            *WriteRequest      `protobuf:"bytes,10,opt,name=write" json:"write,omitempty"`
	Read             *ReadRequest       `protobuf:"bytes,11,opt,name=read" json:"read,omitempty"`
	Stat             *StatRequest       `protobuf:"bytes,12,opt,name=stat" json:"stat,omitempty"`
	Watch            *WatchRequest      `protobuf:"bytes,13,opt,name=watch" json:"watch,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*Request) GetCreate 

func (m *Request) GetCreate() *CreateRequest

func (*Request) GetDelete 

func (m *Request) GetDelete() *DeleteRequest

func (*Request) GetPing 

func (m *Request) GetPing() *PingRequest

func (*Request) GetRead 

func (m *Request) GetRead() *ReadRequest

func (*Request) GetRegister 

func (m *Request) GetRegister() *RegisterRequest

func (*Request) GetSid 

func (m *Request) GetSid() uint64

func (*Request) GetStat 

func (m *Request) GetStat() *StatRequest

func (*Request) GetUnregister 

func (m *Request) GetUnregister() *UnRegisterRequest

func (*Request) GetWatch 

func (m *Request) GetWatch() *WatchRequest

func (*Request) GetWrite 

func (m *Request) GetWrite() *WriteRequest

func (*Request) GetXid 

func (m *Request) GetXid() uint64

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

type Response 

type Response struct {
	Xid              *uint64     `protobuf:"varint,1,opt,name=xid" json:"xid,omitempty"`
	Err              *Error      `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"`
	Data             []byte      `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	Watch            *WatchEvent `protobuf:"bytes,4,opt,name=watch" json:"watch,omitempty"`
	Sid              *uint64     `protobuf:"varint,5,opt,name=sid" json:"sid,omitempty"`
	Path             *string     `protobuf:"bytes,6,opt,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Response) GetData 

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

func (*Response) GetErr 

func (m *Response) GetErr() *Error

func (*Response) GetPath 

func (m *Response) GetPath() string

func (*Response) GetSid 

func (m *Response) GetSid() uint64

func (*Response) GetWatch 

func (m *Response) GetWatch() *WatchEvent

func (*Response) GetXid 

func (m *Response) GetXid() uint64

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

type StatRequest 

type StatRequest struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StatRequest) GetPath 

func (m *StatRequest) GetPath() string

func (*StatRequest) ProtoMessage 

func (*StatRequest) ProtoMessage()

func (*StatRequest) Reset 

func (m *StatRequest) Reset()

func (*StatRequest) String 

func (m *StatRequest) String() string

type UnRegisterRequest 

type UnRegisterRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*UnRegisterRequest) ProtoMessage 

func (*UnRegisterRequest) ProtoMessage()

func (*UnRegisterRequest) Reset 

func (m *UnRegisterRequest) Reset()

func (*UnRegisterRequest) String 

func (m *UnRegisterRequest) String() string

type WatchEvent 

type WatchEvent struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	Type             *uint32 `protobuf:"varint,2,req,name=type" json:"type,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*WatchEvent) GetPath 

func (m *WatchEvent) GetPath() string

func (*WatchEvent) GetType 

func (m *WatchEvent) GetType() uint32

func (*WatchEvent) ProtoMessage 

func (*WatchEvent) ProtoMessage()

func (*WatchEvent) Reset 

func (m *WatchEvent) Reset()

func (*WatchEvent) String 

func (m *WatchEvent) String() string

type WatchRequest 

type WatchRequest struct {
	Path             *string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
	Watch            *uint32 `protobuf:"varint,2,opt,name=watch" json:"watch,omitempty"`
	Recursive        *bool   `protobuf:"varint,3,opt,name=recursive" json:"recursive,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*WatchRequest) GetPath 

func (m *WatchRequest) GetPath() string

func (*WatchRequest) GetRecursive 

func (m *WatchRequest) GetRecursive() bool

func (*WatchRequest) GetWatch 

func (m *WatchRequest) GetWatch() uint32

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset 

func (m *WatchRequest) Reset()

func (*WatchRequest) String 

func (m *WatchRequest) String() string

type WriteRequest 

type WriteRequest struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	Data             []byte  `protobuf:"bytes,2,req,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*WriteRequest) GetData 

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

func (*WriteRequest) GetPath 

func (m *WriteRequest) GetPath() string

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

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.