client

Documentation

Index

• type ClientSendMessageTask
• type Config
• type IClientTask
• type RequestTask
• type Service
  • func (S *Service) Handle(a app.IApp, task app.ITask) error
  • func (S *Service) HandleClientSendMessageTask(a app.IApp, task *ClientSendMessageTask) error
  • func (S *Service) HandleInitTask(a app.IApp, task *app.InitTask) error
  • func (S *Service) HandleRequestTask(a app.IApp, task *RequestTask) error
• type WithService
  • func (S *WithService) Handle(a app.IApp, task app.ITask) error

Types

type ClientSendMessageTask

type ClientSendMessageTask struct {
	app.Task
	Message kk.Message
}

type Config

type Config struct {
	Name    string
	Address string
	Options map[string]interface{}
}

type IClientTask

type IClientTask interface {
	GetClientName() string
	GetInhertType() string
}

type RequestTask

type RequestTask struct {
	app.Task
	Name        string
	TrackId     string
	RequestTask app.ITask
	Request     interface{}
	Result      interface{}
	Timeout     time.Duration
}

type Service

type Service struct {
	app.Service
	Config Config
	// contains filtered or unexported fields
}

func (*Service) Handle

func (S *Service) Handle(a app.IApp, task app.ITask) error

func (*Service) HandleClientSendMessageTask

func (S *Service) HandleClientSendMessageTask(a app.IApp, task *ClientSendMessageTask) error

func (*Service) HandleInitTask

func (S *Service) HandleInitTask(a app.IApp, task *app.InitTask) error

func (*Service) HandleRequestTask

func (S *Service) HandleRequestTask(a app.IApp, task *RequestTask) error

type WithService

type WithService struct {
	app.Service
	Prefix     string
	Timeout    time.Duration
	InhertType string
}

func (*WithService) Handle

func (S *WithService) Handle(a app.IApp, task app.ITask) error