aggregator

Documentation

Index

• Variables
• type SumUint32Aggregator
  • func NewSumUint32Aggregator(name string) *SumUint32Aggregator
  • func (s *SumUint32Aggregator) Aggregate(v1 plugin.AggregatableValue, v2 plugin.AggregatableValue) (plugin.AggregatableValue, error)
  • func (s *SumUint32Aggregator) MarshalValue(v plugin.AggregatableValue) (*types.Any, error)
  • func (s *SumUint32Aggregator) Name() string
  • func (s *SumUint32Aggregator) ToString(v plugin.AggregatableValue) string
  • func (s *SumUint32Aggregator) UnmarshalValue(pb *types.Any) (plugin.AggregatableValue, error)
• type VertexStats
  • func (*VertexStats) Descriptor() ([]byte, []int)
  • func (this *VertexStats) Equal(that interface{}) bool
  • func (m *VertexStats) GetActiveVertices() uint64
  • func (m *VertexStats) GetMessagesSent() uint64
  • func (m *VertexStats) GetTotalVertices() uint64
  • func (this *VertexStats) GoString() string
  • func (m *VertexStats) Marshal() (dAtA []byte, err error)
  • func (m *VertexStats) MarshalTo(dAtA []byte) (int, error)
  • func (*VertexStats) ProtoMessage()
  • func (m *VertexStats) Reset()
  • func (m *VertexStats) Size() (n int)
  • func (this *VertexStats) String() string
  • func (m *VertexStats) Unmarshal(dAtA []byte) error
  • func (m *VertexStats) XXX_DiscardUnknown()
  • func (m *VertexStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *VertexStats) XXX_Merge(src proto.Message)
  • func (m *VertexStats) XXX_Size() int
  • func (m *VertexStats) XXX_Unmarshal(b []byte) error
• type VertexStatsAggregator
  • func (s *VertexStatsAggregator) Aggregate(v1 plugin.AggregatableValue, v2 plugin.AggregatableValue) (plugin.AggregatableValue, error)
  • func (s *VertexStatsAggregator) MarshalValue(v plugin.AggregatableValue) (*types.Any, error)
  • func (s *VertexStatsAggregator) Name() string
  • func (s *VertexStatsAggregator) ToString(v plugin.AggregatableValue) string
  • func (s *VertexStatsAggregator) UnmarshalValue(pb *types.Any) (plugin.AggregatableValue, error)

Variables

var (
	ErrInvalidLengthAggregator = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAggregator   = fmt.Errorf("proto: integer overflow")
)

Types

type SumUint32Aggregator

type SumUint32Aggregator struct {
	// contains filtered or unexported fields
}

SumUint32Aggregator is aggregator for SumUint32Aggregator

func NewSumUint32Aggregator

func NewSumUint32Aggregator(name string) *SumUint32Aggregator

NewSumUint32Aggregator returns a new SumUint32Aggregator instance

func (*SumUint32Aggregator) Aggregate

func (s *SumUint32Aggregator) Aggregate(v1 plugin.AggregatableValue, v2 plugin.AggregatableValue) (plugin.AggregatableValue, error)

Aggregate is reduction func

func (*SumUint32Aggregator) MarshalValue

func (s *SumUint32Aggregator) MarshalValue(v plugin.AggregatableValue) (*types.Any, error)

MarshalValue converts AggregatableValue into uin32

func (*SumUint32Aggregator) Name

func (s *SumUint32Aggregator) Name() string

Name returns aggregator name

func (*SumUint32Aggregator) ToString

func (s *SumUint32Aggregator) ToString(v plugin.AggregatableValue) string

ToString converts aggregatabale value to string

func (*SumUint32Aggregator) UnmarshalValue

func (s *SumUint32Aggregator) UnmarshalValue(pb *types.Any) (plugin.AggregatableValue, error)

UnmarshalValue converts uint32 to AggregatableValue

type VertexStats

type VertexStats struct {
	ActiveVertices uint64 `protobuf:"varint,1,opt,name=active_vertices,json=activeVertices,proto3" json:"active_vertices,omitempty"`
	TotalVertices  uint64 `protobuf:"varint,2,opt,name=total_vertices,json=totalVertices,proto3" json:"total_vertices,omitempty"`
	MessagesSent   uint64 `protobuf:"varint,3,opt,name=messages_sent,json=messagesSent,proto3" json:"messages_sent,omitempty"`
}

func (*VertexStats) Descriptor

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

func (*VertexStats) Equal

func (this *VertexStats) Equal(that interface{}) bool

func (*VertexStats) GetActiveVertices

func (m *VertexStats) GetActiveVertices() uint64

func (*VertexStats) GetMessagesSent

func (m *VertexStats) GetMessagesSent() uint64

func (*VertexStats) GetTotalVertices

func (m *VertexStats) GetTotalVertices() uint64

func (*VertexStats) GoString

func (this *VertexStats) GoString() string

func (*VertexStats) Marshal

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

func (*VertexStats) MarshalTo

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

func (*VertexStats) ProtoMessage

func (*VertexStats) ProtoMessage()

func (*VertexStats) Reset

func (m *VertexStats) Reset()

func (*VertexStats) Size

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

func (*VertexStats) String

func (this *VertexStats) String() string

func (*VertexStats) Unmarshal

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

func (*VertexStats) XXX_DiscardUnknown

func (m *VertexStats) XXX_DiscardUnknown()

func (*VertexStats) XXX_Marshal

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

func (*VertexStats) XXX_Merge

func (m *VertexStats) XXX_Merge(src proto.Message)

func (*VertexStats) XXX_Size

func (m *VertexStats) XXX_Size() int

func (*VertexStats) XXX_Unmarshal

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

type VertexStatsAggregator

type VertexStatsAggregator struct {
	AggName string
}

VertexStatsAggregator is aggregator for VertexStats

func (*VertexStatsAggregator) Aggregate

func (s *VertexStatsAggregator) Aggregate(v1 plugin.AggregatableValue, v2 plugin.AggregatableValue) (plugin.AggregatableValue, error)

Aggregate is reduction func

func (*VertexStatsAggregator) MarshalValue

func (s *VertexStatsAggregator) MarshalValue(v plugin.AggregatableValue) (*types.Any, error)

MarshalValue converts AggregatableValue into types.Any

func (*VertexStatsAggregator) Name

func (s *VertexStatsAggregator) Name() string

Name is aggregator name

func (*VertexStatsAggregator) ToString

func (s *VertexStatsAggregator) ToString(v plugin.AggregatableValue) string

ToString converts into string

func (*VertexStatsAggregator) UnmarshalValue

func (s *VertexStatsAggregator) UnmarshalValue(pb *types.Any) (plugin.AggregatableValue, error)

UnmarshalValue converts types.Any to AggregatableValue