server

package
v0.0.0-...-e67e6ae Latest Latest
Warning

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

Go to latest
Published: Jul 22, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Interface2string

func Interface2string(in interface{}) (out string)

func SubscribeID2Topic

func SubscribeID2Topic(subscribeID string) (topic string)

Types

type Properties

type Properties struct {
	RawData PropertiesRawData `json:"rawData"`
}

type PropertiesRawData

type PropertiesRawData struct {
	Id     string      `json:"id"`
	Mark   string      `json:"mark"`
	Path   string      `json:"path"`
	Ts     int64       `json:"ts"`
	Type   string      `json:"type"`
	Values interface{} `json:"values"`
}

type RawData

type RawData struct {
	Id          string     `json:"id"`
	Owner       string     `json:"owner"`
	Properties  Properties `json:"properties"`
	SubscribeId string     `json:"subscribe_id"`
}

type RuleService

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

func New

func New(ctx context.Context, slotNum int, c *types.ServiceConfig) *RuleService

func (*RuleService) Debug

func (s *RuleService) Debug(ctx context.Context, message xstream.PublishMessage)

func (*RuleService) Destroy

func (s *RuleService) Destroy(ctx context.Context)

@TODO

func (*RuleService) Start

func (s *RuleService) Start(ctx context.Context) error

func (*RuleService) Stop

func (s *RuleService) Stop(ctx context.Context)

@TODO

Jump to

Keyboard shortcuts

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