collector

package

v0.0.0-...-ef9407b Latest Latest Go to latest Published: Nov 15, 2017 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/wangwg2/iot.sentel

Documentation ¶

Index ¶

Constants
Variables
func AsyncReport(c core.Config, topic string, value sarama.Encoder) error
func SyncReport(c core.Config, topic string, value sarama.Encoder) error
type Client
- func (p *Client) Encode() ([]byte, error)
- func (p *Client) Length() int
type CollectorService
- func (s *CollectorService) Name() string
- func (s *CollectorService) Start() error
- func (s *CollectorService) Stop()
type CollectorServiceFactory
- func (m *CollectorServiceFactory) New(name string, c core.Config, ch chan core.ServiceCommand) (core.Service, error)
type Metric
- func (p *Metric) Encode() ([]byte, error)
- func (p *Metric) Length() int
type Node
- func (p *Node) Encode() ([]byte, error)
- func (p *Node) Length() int
type Publish
- func (p *Publish) Encode() ([]byte, error)
- func (p *Publish) Length() int
type Session
- func (p *Session) Encode() ([]byte, error)
- func (p *Session) Length() int
type Stats
- func (p *Stats) Encode() ([]byte, error)
- func (p *Stats) Length() int
type Subscription
- func (p *Subscription) Encode() ([]byte, error)
- func (p *Subscription) Length() int

Constants ¶

View Source

const (
	TopicNameNode         = "/cluster/nodes"
	TopicNameClient       = "/cluster/clients"
	TopicNameSession      = "/cluster/sessions"
	TopicNameSubscription = "/cluster/subscriptions"
	TopicNamePublish      = "/cluster/publish"
	TopicNameMetric       = "/cluster/metrics"
	TopicNameStats        = "/cluster/stats"
)

View Source

const (
	ObjectActionRegister   = "register"
	ObjectActionUnregister = "unregister"
	ObjectActionRetrieve   = "retrieve"
	ObjectActionDelete     = "delete"
	ObjectActionUpdate     = "update"
)

Variables ¶

View Source

var Configs = map[string]string{}

Functions ¶

func AsyncReport ¶

func AsyncReport(c core.Config, topic string, value sarama.Encoder) error

func SyncReport ¶

func SyncReport(c core.Config, topic string, value sarama.Encoder) error

Types ¶

type Client ¶

type Client struct {
	ClientId        string `json:"clientId"`
	UserName        string `json:"userName"`
	IpAddress       string `json:"ipAddress"`
	Port            uint16 `json:"port"`
	CleanSession    bool   `json:"cleanSession"`
	ProtocolVersion string `json:"protocolVersion"`
	Keepalive       uint16 `json:"keepalive"`
	ConnectedAt     string `json:"connectedAt"`
	// contains filtered or unexported fields
}

Client

func (*Client) Encode ¶

func (p *Client) Encode() ([]byte, error)

func (*Client) Length ¶

func (p *Client) Length() int

type CollectorService ¶

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

func (*CollectorService) Name ¶

func (s *CollectorService) Name() string

Name

func (*CollectorService) Start ¶

func (s *CollectorService) Start() error

Start

func (*CollectorService) Stop ¶

func (s *CollectorService) Stop()

Stop

type CollectorServiceFactory ¶

type CollectorServiceFactory struct{}

CollectorServiceFactory

func (*CollectorServiceFactory) New ¶

func (m *CollectorServiceFactory) New(name string, c core.Config, ch chan core.ServiceCommand) (core.Service, error)

New create apiService service factory

type Metric ¶

type Metric struct {
	Action     string            `json:"action"`
	NodeName   string            `json:"nodeName"`
	Service    string            `json:"service"`
	Values     map[string]uint64 `json:"values"`
	UpdateTime time.Time         `json:"updateTime"`
	// contains filtered or unexported fields
}

Metric

func (*Metric) Encode ¶

func (p *Metric) Encode() ([]byte, error)

func (*Metric) Length ¶

func (p *Metric) Length() int

type Node ¶

type Node struct {
	NodeName   string `json:"nodeName"`
	NodeIp     string `json:"nodeIp"`
	Version    string `json:"version"`
	CreatedAt  string `json:"createdAt"`
	NodeStatus string `json:"nodeStatus"`
	Action     string `json:"action"`
	// contains filtered or unexported fields
}

Node

func (*Node) Encode ¶

func (p *Node) Encode() ([]byte, error)

func (*Node) Length ¶

func (p *Node) Length() int

type Publish ¶

type Publish struct {
	ClientId  string `json:"clientId"`
	Topic     string `json:"topic"`
	ProductId string `json:"product"`
	// contains filtered or unexported fields
}

Publish

func (*Publish) Encode ¶

func (p *Publish) Encode() ([]byte, error)

func (*Publish) Length ¶

func (p *Publish) Length() int

type Session ¶

type Session struct {
	Action             string `json:"action"`
	ClientId           string `json:"clientId"`
	CleanSession       bool   `json:"cleanSession"`
	MessageMaxInflight uint64 `json:"messageMaxInflight"`
	MessageInflight    uint64 `json:"messageInflight"`
	MessageInQueue     uint64 `json:"messageInQueue"`
	MessageDropped     uint64 `json:"messageDropped"`
	AwaitingRel        uint64 `json:"awaitingRel"`
	AwaitingComp       uint64 `json:"awaitingComp"`
	AwaitingAck        uint64 `json:"awaitingAck"`
	CreatedAt          string `json:"createdAt"`
	// contains filtered or unexported fields
}

Session

func (*Session) Encode ¶

func (p *Session) Encode() ([]byte, error)

func (*Session) Length ¶

func (p *Session) Length() int

type Stats ¶

type Stats struct {
	NodeName   string            `json:"nodeName"`
	Service    string            `json:"service"`
	Action     string            `json:"action"`
	UpdateTime time.Time         `json:"updateTime"`
	Values     map[string]uint64 `json:"values"`
	// contains filtered or unexported fields
}

Stat

func (*Stats) Encode ¶

func (p *Stats) Encode() ([]byte, error)

func (*Stats) Length ¶

func (p *Stats) Length() int

type Subscription ¶

type Subscription struct {
	ClientId  string    `json:"clientId"`
	Topic     string    `json:"topic"`
	Qos       int       `json:"qos"`
	CreatedAt time.Time `json:"createdAt"`
	Action    string    `json:"action"`
	// contains filtered or unexported fields
}

Subscription

func (*Subscription) Encode ¶

func (p *Subscription) Encode() ([]byte, error)

func (*Subscription) Length ¶

func (p *Subscription) Length() int

Source Files ¶

View all Source files

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