udf

package

Go to main page

Versions in this module

v1

v1.0.0-beta4

Jul 27, 2016

v1.0.0-beta3

Jul 9, 2016

v1.0.0-beta2

Jun 17, 2016

v1.0.0-beta1

Jun 6, 2016

v0

v0.13.1

May 13, 2016

v0.13.0

May 12, 2016

Changes in this version

+ var ErrServerStopped = errors.New("server already stopped")

+ type Info struct

+ Options map[string]*OptionInfo

+ Provides EdgeType

+ Wants EdgeType

+ type Interface interface

+ Abort func(err error)

+ BatchIn func() chan<- models.Batch

+ BatchOut func() <-chan models.Batch

+ Close func() error

+ Info func() (Info, error)

+ Init func(options []*Option) error

+ Open func() error

+ PointIn func() chan<- models.Point

+ PointOut func() <-chan models.Point

+ Restore func(snapshot []byte) error

+ Snapshot func() ([]byte, error)

+ type Server struct

+ func NewServer(in ByteReadReader, out io.WriteCloser, l *log.Logger, timeout time.Duration, ...) *Server

+ func (s *Server) Abort(err error)

+ func (s *Server) BatchIn() chan<- models.Batch

+ func (s *Server) BatchOut() <-chan models.Batch

+ func (s *Server) Info() (Info, error)

+ func (s *Server) Init(options []*Option) error

+ func (s *Server) PointIn() chan<- models.Point

+ func (s *Server) PointOut() <-chan models.Point

+ func (s *Server) Restore(snapshot []byte) error

+ func (s *Server) Snapshot() ([]byte, error)

+ func (s *Server) Start() error

+ func (s *Server) Stop() error

+ func (s *Server) WaitIO()

v0.13.0-rc3

May 10, 2016

v0.13.0-rc2

May 7, 2016

v0.13.0-rc1

May 5, 2016

v0.12.0

Apr 4, 2016

v0.12.0-rc2

Apr 1, 2016

v0.12.0-rc1

Mar 29, 2016

v0.11.0

Mar 22, 2016

Changes in this version

type BeginBatch

+ func (*BeginBatch) Descriptor() ([]byte, []int)

type EdgeType

+ func (EdgeType) EnumDescriptor() ([]byte, []int)

type EndBatch

+ func (*EndBatch) Descriptor() ([]byte, []int)

type ErrorResponse

+ func (*ErrorResponse) Descriptor() ([]byte, []int)

type InfoRequest

+ func (*InfoRequest) Descriptor() ([]byte, []int)

type InfoResponse

+ func (*InfoResponse) Descriptor() ([]byte, []int)

type InitRequest

+ func (*InitRequest) Descriptor() ([]byte, []int)

type InitResponse

+ func (*InitResponse) Descriptor() ([]byte, []int)

type KeepaliveRequest

+ func (*KeepaliveRequest) Descriptor() ([]byte, []int)

type KeepaliveResponse

+ func (*KeepaliveResponse) Descriptor() ([]byte, []int)

type Option

+ func (*Option) Descriptor() ([]byte, []int)

type OptionInfo

+ func (*OptionInfo) Descriptor() ([]byte, []int)

type OptionValue

+ func (*OptionValue) Descriptor() ([]byte, []int)

type Point

+ func (*Point) Descriptor() ([]byte, []int)

type Request

+ func (*Request) Descriptor() ([]byte, []int)

type Response

+ func (*Response) Descriptor() ([]byte, []int)

type RestoreRequest

+ func (*RestoreRequest) Descriptor() ([]byte, []int)

type RestoreResponse

+ func (*RestoreResponse) Descriptor() ([]byte, []int)

type SnapshotRequest

+ func (*SnapshotRequest) Descriptor() ([]byte, []int)

type SnapshotResponse

+ func (*SnapshotResponse) Descriptor() ([]byte, []int)

type ValueType

+ func (ValueType) EnumDescriptor() ([]byte, []int)

v0.11.0-rc3

Mar 21, 2016

v0.11.0-rc2

Mar 17, 2016

v0.11.0-rc1

Mar 14, 2016

v0.10.1

Feb 8, 2016

Changes in this version

type BeginBatch

+ Group string

+ Name string

+ Tags map[string]string

+ func (m *BeginBatch) GetTags() map[string]string

v0.10.0

Jan 26, 2016

Changes in this version

+ var EdgeType_name = map[int32]string

+ var EdgeType_value = map[string]int32

+ var ValueType_name = map[int32]string

+ var ValueType_value = map[string]int32

+ func ReadMessage(buf *[]byte, r ByteReadReader, msg proto.Message) error

+ func WriteMessage(msg proto.Message, w io.Writer) error

+ type BeginBatch struct

+ func (*BeginBatch) ProtoMessage()

+ func (m *BeginBatch) Reset()

+ func (m *BeginBatch) String() string

+ type ByteReadReader interface

+ type EdgeType int32

+ const EdgeType_BATCH

+ const EdgeType_STREAM

+ func (x EdgeType) String() string

+ type EndBatch struct

+ Group string

+ Name string

+ Tags map[string]string

+ Tmax int64

+ func (*EndBatch) ProtoMessage()

+ func (m *EndBatch) GetTags() map[string]string

+ func (m *EndBatch) Reset()

+ func (m *EndBatch) String() string

+ type ErrorResponse struct

+ Error string

+ func (*ErrorResponse) ProtoMessage()

+ func (m *ErrorResponse) Reset()

+ func (m *ErrorResponse) String() string

+ type InfoRequest struct

+ func (*InfoRequest) ProtoMessage()

+ func (m *InfoRequest) Reset()

+ func (m *InfoRequest) String() string

+ type InfoResponse struct

+ Options map[string]*OptionInfo

+ Provides EdgeType

+ Wants EdgeType

+ func (*InfoResponse) ProtoMessage()

+ func (m *InfoResponse) GetOptions() map[string]*OptionInfo

+ func (m *InfoResponse) Reset()

+ func (m *InfoResponse) String() string

+ type InitRequest struct

+ Options []*Option

+ func (*InitRequest) ProtoMessage()

+ func (m *InitRequest) GetOptions() []*Option

+ func (m *InitRequest) Reset()

+ func (m *InitRequest) String() string

+ type InitResponse struct

+ Error string

+ Success bool

+ func (*InitResponse) ProtoMessage()

+ func (m *InitResponse) Reset()

+ func (m *InitResponse) String() string

+ type KeepaliveRequest struct

+ Time int64

+ func (*KeepaliveRequest) ProtoMessage()

+ func (m *KeepaliveRequest) Reset()

+ func (m *KeepaliveRequest) String() string

+ type KeepaliveResponse struct

+ Time int64

+ func (*KeepaliveResponse) ProtoMessage()

+ func (m *KeepaliveResponse) Reset()

+ func (m *KeepaliveResponse) String() string

+ type Option struct

+ Name string

+ Values []*OptionValue

+ func (*Option) ProtoMessage()

+ func (m *Option) GetValues() []*OptionValue

+ func (m *Option) Reset()

+ func (m *Option) String() string

+ type OptionInfo struct

+ ValueTypes []ValueType

+ func (*OptionInfo) ProtoMessage()

+ func (m *OptionInfo) Reset()

+ func (m *OptionInfo) String() string

+ type OptionValue struct

+ Type ValueType

+ Value isOptionValue_Value

+ func (*OptionValue) ProtoMessage()

+ func (*OptionValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *OptionValue) GetBoolValue() bool

+ func (m *OptionValue) GetDoubleValue() float64

+ func (m *OptionValue) GetDurationValue() int64

+ func (m *OptionValue) GetIntValue() int64

+ func (m *OptionValue) GetStringValue() string

+ func (m *OptionValue) GetValue() isOptionValue_Value

+ func (m *OptionValue) Reset()

+ func (m *OptionValue) String() string

+ type OptionValue_BoolValue struct

+ BoolValue bool

+ type OptionValue_DoubleValue struct

+ DoubleValue float64

+ type OptionValue_DurationValue struct

+ DurationValue int64

+ type OptionValue_IntValue struct

+ IntValue int64

+ type OptionValue_StringValue struct

+ StringValue string

+ type Point struct

+ Database string

+ Dimensions []string

+ FieldsDouble map[string]float64

+ FieldsInt map[string]int64

+ FieldsString map[string]string

+ Group string

+ Name string

+ RetentionPolicy string

+ Tags map[string]string

+ Time int64

+ func (*Point) ProtoMessage()

+ func (m *Point) GetFieldsDouble() map[string]float64

+ func (m *Point) GetFieldsInt() map[string]int64

+ func (m *Point) GetFieldsString() map[string]string

+ func (m *Point) GetTags() map[string]string

+ func (m *Point) Reset()

+ func (m *Point) String() string

+ type Request struct

+ Message isRequest_Message

+ func (*Request) ProtoMessage()

+ func (*Request) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Request) GetBegin() *BeginBatch

+ func (m *Request) GetEnd() *EndBatch

+ func (m *Request) GetInfo() *InfoRequest

+ func (m *Request) GetInit() *InitRequest

+ func (m *Request) GetKeepalive() *KeepaliveRequest

+ func (m *Request) GetMessage() isRequest_Message

+ func (m *Request) GetPoint() *Point

+ func (m *Request) GetRestore() *RestoreRequest

+ func (m *Request) GetSnapshot() *SnapshotRequest

+ func (m *Request) Reset()

+ func (m *Request) String() string

+ type Request_Begin struct

+ Begin *BeginBatch

+ type Request_End struct

+ End *EndBatch

+ type Request_Info struct

+ Info *InfoRequest

+ type Request_Init struct

+ Init *InitRequest

+ type Request_Keepalive struct

+ Keepalive *KeepaliveRequest

+ type Request_Point struct

+ Point *Point

+ type Request_Restore struct

+ Restore *RestoreRequest

+ type Request_Snapshot struct

+ Snapshot *SnapshotRequest

+ type Response struct

+ Message isResponse_Message

+ func (*Response) ProtoMessage()

+ func (*Response) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Response) GetBegin() *BeginBatch

+ func (m *Response) GetEnd() *EndBatch

+ func (m *Response) GetError() *ErrorResponse

+ func (m *Response) GetInfo() *InfoResponse

+ func (m *Response) GetInit() *InitResponse

+ func (m *Response) GetKeepalive() *KeepaliveResponse

+ func (m *Response) GetMessage() isResponse_Message

+ func (m *Response) GetPoint() *Point

+ func (m *Response) GetRestore() *RestoreResponse

+ func (m *Response) GetSnapshot() *SnapshotResponse

+ func (m *Response) Reset()

+ func (m *Response) String() string

+ type Response_Begin struct

+ Begin *BeginBatch

+ type Response_End struct

+ End *EndBatch

+ type Response_Error struct

+ Error *ErrorResponse

+ type Response_Info struct

+ Info *InfoResponse

+ type Response_Init struct

+ Init *InitResponse

+ type Response_Keepalive struct

+ Keepalive *KeepaliveResponse

+ type Response_Point struct

+ Point *Point

+ type Response_Restore struct

+ Restore *RestoreResponse

+ type Response_Snapshot struct

+ Snapshot *SnapshotResponse

+ type RestoreRequest struct

+ Snapshot []byte

+ func (*RestoreRequest) ProtoMessage()

+ func (m *RestoreRequest) Reset()

+ func (m *RestoreRequest) String() string

+ type RestoreResponse struct

+ Error string

+ Success bool

+ func (*RestoreResponse) ProtoMessage()

+ func (m *RestoreResponse) Reset()

+ func (m *RestoreResponse) String() string

+ type SnapshotRequest struct

+ func (*SnapshotRequest) ProtoMessage()

+ func (m *SnapshotRequest) Reset()

+ func (m *SnapshotRequest) String() string

+ type SnapshotResponse struct

+ Snapshot []byte

+ func (*SnapshotResponse) ProtoMessage()

+ func (m *SnapshotResponse) Reset()

+ func (m *SnapshotResponse) String() string

+ type ValueType int32

+ const ValueType_BOOL

+ const ValueType_DOUBLE

+ const ValueType_DURATION

+ const ValueType_INT

+ const ValueType_STRING

+ func (x ValueType) String() string

v0.10.0-rc2

Jan 22, 2016

v0.10.0-rc1

Jan 20, 2016

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