service

Documentation

Index

• type IPC
• type Port
  • func (p Port) Close()
  • func (p *Port) PostMessage(obj IPC)
• type Query
  • func (q *Query) Send(v interface{})
• type Service
  • func New() *Service
  • func (svc *Service) Broadcast(jso interface{})
  • func (svc *Service) On(query string, fn func(q *Query))
  • func (s *Service) OnPort(fn func(p *Port))
  • func (s *Service) Run()

Types

type IPC

type IPC struct {
	Type  string          `json:"type"`
	Query string          `json:"query,omitempty"`
	ID    string          `json:"id,omitempty"`
	Data  json.RawMessage `json:"data"`
}

type Port

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

func (Port) Close

func (p Port) Close()

func (*Port) PostMessage

func (p *Port) PostMessage(obj IPC)

type Query

type Query struct {
	Port *Port
	ID   string
	Data json.RawMessage
}

func (*Query) Send

func (q *Query) Send(v interface{})

type Service

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

func New

func New() *Service

func (*Service) Broadcast

func (svc *Service) Broadcast(jso interface{})

func (*Service) On

func (svc *Service) On(query string, fn func(q *Query))

func (*Service) OnPort

func (s *Service) OnPort(fn func(p *Port))

func (*Service) Run

func (s *Service) Run()