service

Documentation

Index

• type CommandService
  • func New(peer peer.Node, name string, path string) (*CommandService, error)
  • func (cs *CommandService) Define(command string, handler router.CommandHandler) error
  • func (cs *CommandService) DefineStream(command string, std router.CommandHandler, stream router.StreamHandler) error
  • func (cs *CommandService) Router() *(router.Router)
  • func (cs *CommandService) Stop()

Types

type CommandService

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

func New

func New(peer peer.Node, name string, path string) (*CommandService, error)

func (*CommandService) Define

func (cs *CommandService) Define(command string, handler router.CommandHandler) error

func (*CommandService) DefineStream

func (cs *CommandService) DefineStream(command string, std router.CommandHandler, stream router.StreamHandler) error

func (*CommandService) Router

func (cs *CommandService) Router() *(router.Router)

func (*CommandService) Stop

func (cs *CommandService) Stop()