netgraph

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Jan 14, 2019 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Separator   = "/"
	NodesBucket = ""
)

Variables

View Source 
var (
	ErrInvalidLengthSelector = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSelector   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Operation_name = map[int32]string{
	0: "NP",
	1: "EQ",
	2: "NE",
	3: "GT",
	4: "GE",
	5: "LT",
	6: "LE",
	7: "OR",
	8: "AND",
}
View Source 
var Operation_value = map[string]int32{
	"NP":  0,
	"EQ":  1,
	"NE":  2,
	"GT":  3,
	"GE":  4,
	"LT":  5,
	"LE":  6,
	"OR":  7,
	"AND": 8,
}
View Source 
var Type_name = map[int32]string{
	0: "String",
	1: "Integer",
}
View Source 
var Type_value = map[string]int32{
	"String":  0,
	"Integer": 1,
}

Functions

This section is empty.

Types

type Bucket 

type Bucket struct {
	Key   string
	Value string
	// contains filtered or unexported fields
}

func (*Bucket) AddBucket 

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

func (*Bucket) AddChild 

func (b *Bucket) AddChild(c Bucket)

func (*Bucket) AddNode 

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

func (Bucket) CheckConflicts 

func (b Bucket) CheckConflicts(b1 Bucket) bool

func (Bucket) Children 

func (b Bucket) Children() []Bucket

func (Bucket) Copy 

func (b Bucket) Copy() Bucket

func (Bucket) Dump 

func (b Bucket) Dump(name string) error

func (Bucket) DumpWithSelection 

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

func (Bucket) Equals 

func (b Bucket) Equals(b1 Bucket) bool

func (*Bucket) FindGraph 

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

func (*Bucket) FindNodes 

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

func (Bucket) GetMaxSelection 

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

GetMaxSelection returns 'maximal container' -- subgraph which contains any other subgraph satisfying specified selects and filters.

func (Bucket) GetNodesByOption 

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

func (Bucket) GetSelection 

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

func (Bucket) IsValid 

func (b Bucket) IsValid() bool

IsValid checks if bucket is well-formed: - all nodes contained in sub-bucket must belong to this - there must be no nodes belonging to 2 buckets

func (Bucket) MarshalBinary 

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

func (*Bucket) Merge 

func (b *Bucket) Merge(b1 Bucket)

func (Bucket) Name 

func (b Bucket) Name() string

func (Bucket) Nodelist 

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

func (*Bucket) Read 

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

func (Bucket) Sdump 

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

func (Bucket) SdumpWithSelection 

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

func (*Bucket) UnmarshalBinary 

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

func (*Bucket) UpdateIndices 

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

func (Bucket) Write 

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

Writes Bucket with this byte structure [lnName][Name][lnNodes][Node1]...[NodeN][lnSubprops][sub1]...[subN]

type Filter 

type Filter struct {
	Key                  string        `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	F                    *SimpleFilter `protobuf:"bytes,2,opt,name=F" json:"F,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (Filter) Check 

func (f Filter) Check(b Bucket) bool

func (*Filter) Descriptor 

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

func (Filter) Filter 

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

func (*Filter) GetF 

func (m *Filter) GetF() *SimpleFilter

func (*Filter) GetKey 

func (m *Filter) GetKey() string

func (*Filter) Marshal 

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

func (*Filter) MarshalTo 

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

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) Size 

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

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) Unmarshal 

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

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

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

func (*Filter) XXX_Merge 

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

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

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

type FilterFunc 

type FilterFunc func([]int32) []int32

type Graph 

type Graph = *gographviz.Graph

type Int32Slice 

type Int32Slice []int32

func (Int32Slice) Len 

func (p Int32Slice) Len() int

func (Int32Slice) Less 

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

func (Int32Slice) Swap 

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

type Operation 

type Operation int32
const (
	Operation_NP  Operation = 0
	Operation_EQ  Operation = 1
	Operation_NE  Operation = 2
	Operation_GT  Operation = 3
	Operation_GE  Operation = 4
	Operation_LT  Operation = 5
	Operation_LE  Operation = 6
	Operation_OR  Operation = 7
	Operation_AND Operation = 8
)

func (Operation) EnumDescriptor 

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

func (Operation) String 

func (x Operation) String() string

type Policy 

type Policy struct {
	Size       int64
	ReplFactor int
	NodeCount  int
}

type Select 

type Select struct {
	Count                int32    `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
	Key                  string   `protobuf:"bytes,2,opt,name=Key,proto3" json:"Key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Select) Descriptor 

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

func (*Select) GetCount 

func (m *Select) GetCount() int32

func (*Select) GetKey 

func (m *Select) GetKey() string

func (*Select) Marshal 

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

func (*Select) MarshalTo 

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

func (*Select) ProtoMessage 

func (*Select) ProtoMessage()

func (*Select) Reset 

func (m *Select) Reset()

func (*Select) Size 

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

func (*Select) String 

func (m *Select) String() string

func (*Select) Unmarshal 

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

func (*Select) XXX_DiscardUnknown 

func (m *Select) XXX_DiscardUnknown()

func (*Select) XXX_Marshal 

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

func (*Select) XXX_Merge 

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

func (*Select) XXX_Size 

func (m *Select) XXX_Size() int

func (*Select) XXX_Unmarshal 

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

type Selector 

type Selector struct {
	Filters              []Filter `protobuf:"bytes,1,rep,name=Filters" json:"Filters"`
	Selectors            []Select `protobuf:"bytes,2,rep,name=Selectors" json:"Selectors"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Selector) Descriptor 

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

func (*Selector) GetFilters 

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

func (*Selector) GetSelectors 

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

func (*Selector) Marshal 

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

func (*Selector) MarshalTo 

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

func (*Selector) ProtoMessage 

func (*Selector) ProtoMessage()

func (*Selector) Reset 

func (m *Selector) Reset()

func (*Selector) Size 

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

func (*Selector) String 

func (m *Selector) String() string

func (*Selector) Unmarshal 

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

func (*Selector) XXX_DiscardUnknown 

func (m *Selector) XXX_DiscardUnknown()

func (*Selector) XXX_Marshal 

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

func (*Selector) XXX_Merge 

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

func (*Selector) XXX_Size 

func (m *Selector) XXX_Size() int

func (*Selector) XXX_Unmarshal 

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

type SimpleFilter 

type SimpleFilter struct {
	Op Operation `protobuf:"varint,1,opt,name=Op,proto3,enum=netgraph.Operation" json:"Op,omitempty"`
	// Types that are valid to be assigned to Args:
	//	*SimpleFilter_Value
	//	*SimpleFilter_FArgs
	Args                 isSimpleFilter_Args `protobuf_oneof:"Args"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func FilterAND 

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

func FilterEQ 

func FilterEQ(v string) *SimpleFilter

func FilterGE 

func FilterGE(v int64) *SimpleFilter

func FilterGT 

func FilterGT(v int64) *SimpleFilter

func FilterIn 

func FilterIn(values ...string) *SimpleFilter

func FilterLE 

func FilterLE(v int64) *SimpleFilter

func FilterLT 

func FilterLT(v int64) *SimpleFilter

func FilterNE 

func FilterNE(v string) *SimpleFilter

func FilterNotIn 

func FilterNotIn(values ...string) *SimpleFilter

func FilterOR 

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

func NewFilter 

func NewFilter(op Operation, value string) *SimpleFilter

func (SimpleFilter) Check 

func (sf SimpleFilter) Check(value string) bool

func (*SimpleFilter) Descriptor 

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

func (*SimpleFilter) GetArgs 

func (m *SimpleFilter) GetArgs() isSimpleFilter_Args

func (*SimpleFilter) GetFArgs 

func (m *SimpleFilter) GetFArgs() *SimpleFilters

func (*SimpleFilter) GetOp 

func (m *SimpleFilter) GetOp() Operation

func (*SimpleFilter) GetValue 

func (m *SimpleFilter) GetValue() string

func (*SimpleFilter) Marshal 

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

func (*SimpleFilter) MarshalTo 

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

func (*SimpleFilter) ProtoMessage 

func (*SimpleFilter) ProtoMessage()

func (*SimpleFilter) Reset 

func (m *SimpleFilter) Reset()

func (*SimpleFilter) Size 

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

func (*SimpleFilter) String 

func (m *SimpleFilter) String() string

func (*SimpleFilter) Unmarshal 

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

func (*SimpleFilter) XXX_DiscardUnknown 

func (m *SimpleFilter) XXX_DiscardUnknown()

func (*SimpleFilter) XXX_Marshal 

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

func (*SimpleFilter) XXX_Merge 

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

func (*SimpleFilter) XXX_OneofFuncs 

func (*SimpleFilter) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*SimpleFilter) XXX_Size 

func (m *SimpleFilter) XXX_Size() int

func (*SimpleFilter) XXX_Unmarshal 

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

type SimpleFilter_FArgs 

type SimpleFilter_FArgs struct {
	FArgs *SimpleFilters `protobuf:"bytes,3,opt,name=FArgs,oneof"`
}

func (*SimpleFilter_FArgs) MarshalTo 

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

func (*SimpleFilter_FArgs) Size 

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

type SimpleFilter_Value 

type SimpleFilter_Value struct {
	Value string `protobuf:"bytes,2,opt,name=Value,proto3,oneof"`
}

func (*SimpleFilter_Value) MarshalTo 

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

func (*SimpleFilter_Value) Size 

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

type SimpleFilters 

type SimpleFilters struct {
	Filters              []*SimpleFilter `protobuf:"bytes,1,rep,name=Filters" json:"Filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*SimpleFilters) Descriptor 

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

func (*SimpleFilters) GetFilters 

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

func (*SimpleFilters) Marshal 

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

func (*SimpleFilters) MarshalTo 

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

func (*SimpleFilters) ProtoMessage 

func (*SimpleFilters) ProtoMessage()

func (*SimpleFilters) Reset 

func (m *SimpleFilters) Reset()

func (*SimpleFilters) Size 

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

func (*SimpleFilters) String 

func (m *SimpleFilters) String() string

func (*SimpleFilters) Unmarshal 

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

func (*SimpleFilters) XXX_DiscardUnknown 

func (m *SimpleFilters) XXX_DiscardUnknown()

func (*SimpleFilters) XXX_Marshal 

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

func (*SimpleFilters) XXX_Merge 

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

func (*SimpleFilters) XXX_Size 

func (m *SimpleFilters) XXX_Size() int

func (*SimpleFilters) XXX_Unmarshal 

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

type Type 

type Type int32
const (
	Type_String  Type = 0
	Type_Integer Type = 1
)

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) 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.