netgraph

package

Go to main page

Versions in this module

v1

v1.0.6

Feb 7, 2019

Changes in this version

+ type PlacementRule struct

+ ReplFactor uint32

+ SFGroups []SFGroup

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PlacementRule) ProtoMessage()

+ func (m *PlacementRule) GetReplFactor() uint32

+ func (m *PlacementRule) GetSFGroups() []SFGroup

+ func (m *PlacementRule) Marshal() (dAtA []byte, err error)

+ func (m *PlacementRule) MarshalTo(dAtA []byte) (int, error)

+ func (m *PlacementRule) Reset()

+ func (m *PlacementRule) Size() (n int)

+ func (m *PlacementRule) String() string

+ func (m *PlacementRule) Unmarshal(dAtA []byte) error

+ func (m *PlacementRule) XXX_DiscardUnknown()

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

+ func (m *PlacementRule) XXX_Merge(src proto.Message)

+ func (m *PlacementRule) XXX_Size() int

+ func (m *PlacementRule) XXX_Unmarshal(b []byte) error

v1.0.5

Feb 6, 2019

Changes in this version

+ type SFGroup struct

+ Filters []Filter

+ Selectors []Select

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SFGroup) ProtoMessage()

+ func (dst *SFGroup) XXX_Merge(src proto.Message)

+ func (m *SFGroup) GetFilters() []Filter

+ func (m *SFGroup) GetSelectors() []Select

+ func (m *SFGroup) Marshal() (dAtA []byte, err error)

+ func (m *SFGroup) MarshalTo(dAtA []byte) (int, error)

+ func (m *SFGroup) Reset()

+ func (m *SFGroup) Size() (n int)

+ func (m *SFGroup) String() string

+ func (m *SFGroup) Unmarshal(dAtA []byte) error

+ func (m *SFGroup) XXX_DiscardUnknown()

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

+ func (m *SFGroup) XXX_Size() int

+ func (m *SFGroup) XXX_Unmarshal(b []byte) error

v1.0.4

Feb 1, 2019

Changes in this version

type Bucket

+ func (b Bucket) Hash() uint64

v1.0.3

Jan 24, 2019

v1.0.2

Jan 14, 2019

v1.0.1

Jan 14, 2019

v1.0.0

Jan 3, 2019

Changes in this version

+ const NodesBucket

+ const Separator

+ var ErrIntOverflowSelector = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthSelector = fmt.Errorf("proto: negative length found during unmarshaling")

+ var Operation_name = map[int32]string

+ var Operation_value = map[string]int32

+ var Type_name = map[int32]string

+ var Type_value = map[string]int32

+ type Bucket struct

+ Key string

+ Value string

+ func (b *Bucket) AddBucket(o string, n []int32) error

+ func (b *Bucket) AddChild(c Bucket)

+ func (b *Bucket) AddNode(n int32, opts ...string) error

+ func (b *Bucket) FindGraph(rnd *rand.Rand, ss ...Selector) (c *Bucket)

+ func (b *Bucket) FindNodes(rnd *rand.Rand, ss ...Selector) (nodes []int32)

+ func (b *Bucket) Merge(b1 Bucket)

+ func (b *Bucket) Read(r io.Reader) error

+ func (b *Bucket) UnmarshalBinary(data []byte) (err error)

+ func (b *Bucket) UpdateIndices(tr map[int32]int32) Bucket

+ func (b Bucket) CheckConflicts(b1 Bucket) bool

+ func (b Bucket) Children() []Bucket

+ func (b Bucket) Copy() Bucket

+ func (b Bucket) Dump(name string) error

+ func (b Bucket) DumpWithSelection(name string, b1 Bucket) error

+ func (b Bucket) Equals(b1 Bucket) bool

+ func (b Bucket) GetMaxSelection(ss []Select, fs []Filter) (r *Bucket)

+ func (b Bucket) GetNodesByOption(opts ...string) []int32

+ func (b Bucket) GetSelection(ss []Select, rnd *rand.Rand) *Bucket

+ func (b Bucket) IsValid() bool

+ func (b Bucket) MarshalBinary() ([]byte, error)

+ func (b Bucket) Name() string

+ func (b Bucket) Nodelist() (r []int32)

+ func (b Bucket) Sdump() (string, error)

+ func (b Bucket) SdumpWithSelection(b1 Bucket) (string, error)

+ func (b Bucket) Write(w io.Writer) error

+ type Filter struct

+ F *SimpleFilter

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Filter) ProtoMessage()

+ func (dst *Filter) XXX_Merge(src proto.Message)

+ func (f Filter) Check(b Bucket) bool

+ func (f Filter) Filter(bs ...Bucket) []Bucket

+ func (m *Filter) GetF() *SimpleFilter

+ func (m *Filter) GetKey() string

+ func (m *Filter) Marshal() (dAtA []byte, err error)

+ func (m *Filter) MarshalTo(dAtA []byte) (int, error)

+ func (m *Filter) Reset()

+ func (m *Filter) Size() (n int)

+ func (m *Filter) String() string

+ func (m *Filter) Unmarshal(dAtA []byte) error

+ func (m *Filter) XXX_DiscardUnknown()

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

+ func (m *Filter) XXX_Size() int

+ func (m *Filter) XXX_Unmarshal(b []byte) error

+ type FilterFunc func([]int32) []int32

+ type Graph = *gographviz.Graph

+ type Int32Slice []int32

+ func (p Int32Slice) Len() int

+ func (p Int32Slice) Less(i, j int) bool

+ func (p Int32Slice) Swap(i, j int)

+ type Operation int32

+ const Operation_AND

+ const Operation_EQ

+ const Operation_GE

+ const Operation_GT

+ const Operation_LE

+ const Operation_LT

+ const Operation_NE

+ const Operation_NP

+ const Operation_OR

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

+ func (x Operation) String() string

+ type Policy struct

+ NodeCount int

+ ReplFactor int

+ Size int64

+ type Select struct

+ Count int32

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Select) ProtoMessage()

+ func (dst *Select) XXX_Merge(src proto.Message)

+ func (m *Select) GetCount() int32

+ func (m *Select) GetKey() string

+ func (m *Select) Marshal() (dAtA []byte, err error)

+ func (m *Select) MarshalTo(dAtA []byte) (int, error)

+ func (m *Select) Reset()

+ func (m *Select) Size() (n int)

+ func (m *Select) String() string

+ func (m *Select) Unmarshal(dAtA []byte) error

+ func (m *Select) XXX_DiscardUnknown()

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

+ func (m *Select) XXX_Size() int

+ func (m *Select) XXX_Unmarshal(b []byte) error

+ type Selector struct

+ Filters []Filter

+ Selectors []Select

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Selector) ProtoMessage()

+ func (dst *Selector) XXX_Merge(src proto.Message)

+ func (m *Selector) GetFilters() []Filter

+ func (m *Selector) GetSelectors() []Select

+ func (m *Selector) Marshal() (dAtA []byte, err error)

+ func (m *Selector) MarshalTo(dAtA []byte) (int, error)

+ func (m *Selector) Reset()

+ func (m *Selector) Size() (n int)

+ func (m *Selector) String() string

+ func (m *Selector) Unmarshal(dAtA []byte) error

+ func (m *Selector) XXX_DiscardUnknown()

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

+ func (m *Selector) XXX_Size() int

+ func (m *Selector) XXX_Unmarshal(b []byte) error

+ type SimpleFilter struct

+ Args isSimpleFilter_Args

+ Op Operation

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FilterAND(fs ...*SimpleFilter) *SimpleFilter

+ func FilterEQ(v string) *SimpleFilter

+ func FilterGE(v int64) *SimpleFilter

+ func FilterGT(v int64) *SimpleFilter

+ func FilterIn(values ...string) *SimpleFilter

+ func FilterLE(v int64) *SimpleFilter

+ func FilterLT(v int64) *SimpleFilter

+ func FilterNE(v string) *SimpleFilter

+ func FilterNotIn(values ...string) *SimpleFilter

+ func FilterOR(fs ...*SimpleFilter) *SimpleFilter

+ func NewFilter(op Operation, value string) *SimpleFilter

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

+ func (*SimpleFilter) ProtoMessage()

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

+ func (dst *SimpleFilter) XXX_Merge(src proto.Message)

+ func (m *SimpleFilter) GetArgs() isSimpleFilter_Args

+ func (m *SimpleFilter) GetFArgs() *SimpleFilters

+ func (m *SimpleFilter) GetOp() Operation

+ func (m *SimpleFilter) GetValue() string

+ func (m *SimpleFilter) Marshal() (dAtA []byte, err error)

+ func (m *SimpleFilter) MarshalTo(dAtA []byte) (int, error)

+ func (m *SimpleFilter) Reset()

+ func (m *SimpleFilter) Size() (n int)

+ func (m *SimpleFilter) String() string

+ func (m *SimpleFilter) Unmarshal(dAtA []byte) error

+ func (m *SimpleFilter) XXX_DiscardUnknown()

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

+ func (m *SimpleFilter) XXX_Size() int

+ func (m *SimpleFilter) XXX_Unmarshal(b []byte) error

+ func (sf SimpleFilter) Check(value string) bool

+ type SimpleFilter_FArgs struct

+ FArgs *SimpleFilters

+ func (m *SimpleFilter_FArgs) MarshalTo(dAtA []byte) (int, error)

+ func (m *SimpleFilter_FArgs) Size() (n int)

+ type SimpleFilter_Value struct

+ Value string

+ func (m *SimpleFilter_Value) MarshalTo(dAtA []byte) (int, error)

+ func (m *SimpleFilter_Value) Size() (n int)

+ type SimpleFilters struct

+ Filters []*SimpleFilter

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SimpleFilters) ProtoMessage()

+ func (dst *SimpleFilters) XXX_Merge(src proto.Message)

+ func (m *SimpleFilters) GetFilters() []*SimpleFilter

+ func (m *SimpleFilters) Marshal() (dAtA []byte, err error)

+ func (m *SimpleFilters) MarshalTo(dAtA []byte) (int, error)

+ func (m *SimpleFilters) Reset()

+ func (m *SimpleFilters) Size() (n int)

+ func (m *SimpleFilters) String() string

+ func (m *SimpleFilters) Unmarshal(dAtA []byte) error

+ func (m *SimpleFilters) XXX_DiscardUnknown()

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

+ func (m *SimpleFilters) XXX_Size() int

+ func (m *SimpleFilters) XXX_Unmarshal(b []byte) error

+ type Type int32

+ const Type_Integer

+ const Type_String

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

+ func (x Type) String() string

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