service

Documentation

Index

• func NextIPC(curIPC string, ipcList []string) string
• type IpcManager
  • func GetIpcManager() *IpcManager
  • func (im *IpcManager) ChangeIPC()
  • func (im *IpcManager) EnableSwitchIPC()
  • func (im *IpcManager) ForceChangeIPC()
  • func (im *IpcManager) GetIPC() string
  • func (im *IpcManager) SetIPC(ipcs []string) error
  • func (im *IpcManager) Subscribe(sub *IpcSubscriber)
• type IpcSubscriber

Functions

func NextIPC

func NextIPC(curIPC string, ipcList []string) string

NextIPC get next ipc from a list

Types

type IpcManager

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

IpcManager has the global IPC, it takes care of informing all fetcher when IPC is changed

func GetIpcManager

func GetIpcManager() *IpcManager

GetIpcManager singleton impl

func (*IpcManager) ChangeIPC

func (im *IpcManager) ChangeIPC()

ChangeIPC change IPC and inform all subscribers about the change

func (*IpcManager) EnableSwitchIPC

func (im *IpcManager) EnableSwitchIPC()

EnableSwitchIPC enable ForceChangeIPC

func (*IpcManager) ForceChangeIPC

func (im *IpcManager) ForceChangeIPC()

ForceChangeIPC force change ipc, otherwise panic

func (*IpcManager) GetIPC

func (im *IpcManager) GetIPC() string

GetIPC getter for ipc

func (*IpcManager) SetIPC

func (im *IpcManager) SetIPC(ipcs []string) error

SetIPC gets called from main

func (*IpcManager) Subscribe

func (im *IpcManager) Subscribe(sub *IpcSubscriber)

Subscribe method for a subscriber to call

type IpcSubscriber

type IpcSubscriber interface {
	IpcUpdated(ipc string)
	Name() string
}

IpcSubscriber interface for subscribers