invalidator

Documentation

Index

• func StartCacheInvalidator(ctx context.Context, kafkaConf kafka.Config, topics []string, ...) error
• func StartCacheInvalidatorAll(ctx context.Context, kafkaConf kafka.Config, topics []string, ...) error
• func StartCacheInvalidatorDeviceType(ctx context.Context, kafkaConf kafka.Config, deviceTypeTopic string, ...) error
• func StartKnownCacheInvalidators(ctx context.Context, kafkaConf kafka.Config, knownTopics KnownTopics, ...) error
• type Command
• type KnownTopics
• type SignalInfo
• type SignalMapper
  • func GetCommandSignalMapper(sig signal.Signal) SignalMapper
  • func GetKnownSignalMapper(topics KnownTopics) SignalMapper

Functions

func StartCacheInvalidator

func StartCacheInvalidator(ctx context.Context, kafkaConf kafka.Config, topics []string, mapper SignalMapper, broker *signal.Broker) error

func StartCacheInvalidatorAll

func StartCacheInvalidatorAll(ctx context.Context, kafkaConf kafka.Config, topics []string, broker *signal.Broker) error

func StartCacheInvalidatorDeviceType

func StartCacheInvalidatorDeviceType(ctx context.Context, kafkaConf kafka.Config, deviceTypeTopic string, broker *signal.Broker) error

StartCacheInvalidatorDeviceType is manly an example. most should use StartKnownCacheInvalidators or StartCacheInvalidatorAll

func StartKnownCacheInvalidators

func StartKnownCacheInvalidators(ctx context.Context, kafkaConf kafka.Config, knownTopics KnownTopics, broker *signal.Broker) error

Types

type Command

type Command struct {
	Command string `json:"command"`
	Id      string `json:"id"`
}

type KnownTopics

type KnownTopics struct {
	DeviceTopic         string
	DeviceTypeTopic     string
	ConceptTopic        string
	CharacteristicTopic string
	FunctionTopic       string
	AspectTopic         string
	HubTopic            string
	DeviceClassTopic    string
	DeviceGroupTopic    string
	ProtocolTopic       string
	LocationTopic       string
}

type SignalInfo

type SignalInfo struct {
	Signal      signal.Signal
	SignalValue string
}

type SignalMapper

type SignalMapper = func(message kafka.Message) []SignalInfo

func GetCommandSignalMapper

func GetCommandSignalMapper(sig signal.Signal) SignalMapper

func GetKnownSignalMapper

func GetKnownSignalMapper(topics KnownTopics) SignalMapper