store

Documentation

Index

• type PipeInfo
  • func (info *PipeInfo) Channel() chan model.Message
  • func (info *PipeInfo) Socket() net.Conn
  • func (info *PipeInfo) Wrapper() wrapper.Conn
• type PipeStore
  • func NewPipeStore() *PipeStore
  • func (s *PipeStore) Add(module string, pipe interface{})
  • func (s *PipeStore) AddGroup(module, group string, pipe interface{})
  • func (s *PipeStore) Delete(module string)
  • func (s *PipeStore) Get(module string) (PipeInfo, error)
  • func (s *PipeStore) GetGroup(group string) map[string]PipeInfo
  • func (s *PipeStore) WalkGroup(group string, walkFunc func(string, PipeInfo) error) error

Types

type PipeInfo

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

PipeInfo pipe info

func (*PipeInfo) Channel

func (info *PipeInfo) Channel() chan model.Message

Channel channel

func (*PipeInfo) Socket

func (info *PipeInfo) Socket() net.Conn

Socket socket

func (*PipeInfo) Wrapper

func (info *PipeInfo) Wrapper() wrapper.Conn

Wrapper wrapper

type PipeStore

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

PipeStore pipe store

func NewPipeStore

func NewPipeStore() *PipeStore

NewPipeStore new pipe store

func (*PipeStore) Add

func (s *PipeStore) Add(module string, pipe interface{})

Add add

func (*PipeStore) AddGroup

func (s *PipeStore) AddGroup(module, group string, pipe interface{})

AddGroup add group

func (*PipeStore) Delete

func (s *PipeStore) Delete(module string)

Delete delete

func (*PipeStore) Get

func (s *PipeStore) Get(module string) (PipeInfo, error)

Get get

func (*PipeStore) GetGroup

func (s *PipeStore) GetGroup(group string) map[string]PipeInfo

GetGroup get group

func (*PipeStore) WalkGroup

func (s *PipeStore) WalkGroup(group string, walkFunc func(string, PipeInfo) error) error

WalkGroup walk group