client

Documentation

Index

• type HostClient
  • func NewHostClient(wsURL string) *HostClient
  • func (hc *HostClient) Call(ctx context.Context, action string, payload interface{}) *json.RawMessage
  • func (hc *HostClient) CallAndForget(action string, payload interface{})
  • func (hc *HostClient) Close()
  • func (hc *HostClient) CloseAppClients(pageName string)
  • func (hc *HostClient) PageNewSessions(pageName string) chan string
  • func (hc *HostClient) RegisterPage(ctx context.Context, request *page.RegisterHostClientRequestPayload) (*page.RegisterHostClientResponsePayload, error)
  • func (hc *HostClient) RegisterPipeClient(pc *PipeClient) error
  • func (hc *HostClient) Start() (err error)
  • func (hc *HostClient) UnregisterPipeClient(pc *PipeClient)
• type PageRegistration
• type PipeClient
  • func NewPipeClient(pageName string, sessionID string, hc *HostClient, uds bool, ...) (*PipeClient, error)
  • func (pc *PipeClient) CommandPipeName() string
  • func (pc *PipeClient) Start() error

Types

type HostClient

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

func NewHostClient

func NewHostClient(wsURL string) *HostClient

func (*HostClient) Call

func (hc *HostClient) Call(ctx context.Context, action string, payload interface{}) *json.RawMessage

func (*HostClient) CallAndForget

func (hc *HostClient) CallAndForget(action string, payload interface{})

func (*HostClient) Close

func (hc *HostClient) Close()

func (*HostClient) CloseAppClients

func (hc *HostClient) CloseAppClients(pageName string)

func (*HostClient) PageNewSessions

func (hc *HostClient) PageNewSessions(pageName string) chan string

func (*HostClient) RegisterPage

func (hc *HostClient) RegisterPage(ctx context.Context, request *page.RegisterHostClientRequestPayload) (*page.RegisterHostClientResponsePayload, error)

func (*HostClient) RegisterPipeClient

func (hc *HostClient) RegisterPipeClient(pc *PipeClient) error

func (*HostClient) Start

func (hc *HostClient) Start() (err error)

func (*HostClient) UnregisterPipeClient

func (hc *HostClient) UnregisterPipeClient(pc *PipeClient)

type PageRegistration

type PageRegistration struct {
	RegistrationRequest *page.RegisterHostClientRequestPayload
	Sessions            map[string]map[*PipeClient]bool
}

type PipeClient

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

func NewPipeClient

func NewPipeClient(pageName string, sessionID string, hc *HostClient, uds bool, emitAllEvents bool, tickerDuration int) (*PipeClient, error)

func (*PipeClient) CommandPipeName

func (pc *PipeClient) CommandPipeName() string

func (*PipeClient) Start

func (pc *PipeClient) Start() error