decoder

Documentation

Index

• Constants
• type Counter
• type Decoder
  • func NewDecoder(eventType common.EventType, inQueue queue.QueueReader, ...) *Decoder
  • func (d *Decoder) GetCounter() interface{}
  • func (d *Decoder) Run()
• type ResourceInfo
• type ResourceInfoTable
  • func NewResourceInfoTable(ips []net.IP, port, rpcMaxMsgSize int) *ResourceInfoTable
  • func (p *ResourceInfoTable) Close()
  • func (p *ResourceInfoTable) QueryResourceInfo(resourceType uint32, resourceID uint32) *ResourceInfo
  • func (p *ResourceInfoTable) Reload() error
  • func (p *ResourceInfoTable) Start()

Constants

const (
	BUFFER_SIZE = 1024
)

Types

type Counter

type Counter struct {
	InCount    int64 `statsd:"in-count"`
	OutCount   int64 `statsd:"out-count"`
	ErrorCount int64 `statsd:"err-count"`
}

type Decoder

type Decoder struct {
	utils.Closable
	// contains filtered or unexported fields
}

func NewDecoder

func NewDecoder(
	eventType common.EventType,
	inQueue queue.QueueReader,
	eventWriter *dbwriter.EventWriter,
	config *config.Config,
) *Decoder

func (*Decoder) GetCounter

func (d *Decoder) GetCounter() interface{}

func (*Decoder) Run

func (d *Decoder) Run()

type ResourceInfo

type ResourceInfo struct {
	L3EpcID      int32
	HostID       uint32
	RegionID     uint32
	L3DeviceType uint32
	L3DeviceID   uint32
	PodNodeID    uint32
	PodNSID      uint32
	PodGroupID   uint32
	PodID        uint32
	PodClusterID uint32
	AZID         uint32
}

type ResourceInfoTable

type ResourceInfoTable struct {
	GrpcSession *grpc.GrpcSession
	// contains filtered or unexported fields
}

func NewResourceInfoTable

func NewResourceInfoTable(ips []net.IP, port, rpcMaxMsgSize int) *ResourceInfoTable

func (*ResourceInfoTable) Close

func (p *ResourceInfoTable) Close()

func (*ResourceInfoTable) QueryResourceInfo

func (p *ResourceInfoTable) QueryResourceInfo(resourceType uint32, resourceID uint32) *ResourceInfo

func (*ResourceInfoTable) Reload

func (p *ResourceInfoTable) Reload() error

func (*ResourceInfoTable) Start

func (p *ResourceInfoTable) Start()