notification

Documentation

Overview

Package notification provides functions to manage notification after running service application

Index

• Constants
• type ConcurrentMap
  • func (cm *ConcurrentMap) Get(key uint64) (interface{}, bool)
  • func (cm *ConcurrentMap) Remove(key uint64)
  • func (cm *ConcurrentMap) Set(key uint64, value interface{})
• type ConcurrentMapItem
• type HasNotification
  • func (n *HasNotification) SetNotiImpl(noti Notification)
• type NotiImpl
  • func GetInstance() *NotiImpl
  • func (NotiImpl) AddNotificationChan(serviceID uint64, notiChan chan string)
  • func (NotiImpl) HandleNotificationOnLocal(serviceID float64, status string) (err error)
  • func (n NotiImpl) InvokeNotification(target string, serviceID float64, status string) (err error)
• type Notification

Constants

const (
	// ConstKeyNotiChan is key of notification channel
	ConstKeyNotiChan = "NotiChan"
)

Types

type ConcurrentMap

type ConcurrentMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ConcurrentMap type

func (*ConcurrentMap) Get

func (cm *ConcurrentMap) Get(key uint64) (interface{}, bool)

Get is for getting map item

func (*ConcurrentMap) Remove

func (cm *ConcurrentMap) Remove(key uint64)

Remove is for removing map item

func (*ConcurrentMap) Set

func (cm *ConcurrentMap) Set(key uint64, value interface{})

Set is for setting map item

type ConcurrentMapItem

type ConcurrentMapItem struct {
	Key   uint64
	Value interface{}
}

ConcurrentMapItem type

type HasNotification

type HasNotification struct {
	NotiImplIns Notification
}

HasNotification struct

func (*HasNotification) SetNotiImpl

func (n *HasNotification) SetNotiImpl(noti Notification)

SetNotiImpl for setting notification implementation

type NotiImpl

type NotiImpl struct {
	client.HasClient
}

NotiImpl Structure

func GetInstance

func GetInstance() *NotiImpl

GetInstance returns the singleton NotiImpl instance

func (NotiImpl) AddNotificationChan

func (NotiImpl) AddNotificationChan(serviceID uint64, notiChan chan string)

AddNotificationChan is adding notification channel value with service ID key

func (NotiImpl) HandleNotificationOnLocal

func (NotiImpl) HandleNotificationOnLocal(serviceID float64, status string) (err error)

HandleNotificationOnLocal is invoking notification on local

func (NotiImpl) InvokeNotification

func (n NotiImpl) InvokeNotification(target string, serviceID float64, status string) (err error)

InvokeNotification is processing notification

type Notification

type Notification interface {
	InvokeNotification(target string, serviceID float64, status string) error
	AddNotificationChan(serviceID uint64, notiChan chan string)
	HandleNotificationOnLocal(serviceID float64, status string) (err error)

	// for client
	client.Setter
}

Notification is the interface for notification