remote

Documentation

Index

• type Config
• type Counter
• type RemoteReceiveMessageTask
• type RemoteSendMessageTask
• type Service
  • func (S *Service) Handle(a app.IApp, task app.ITask) error
  • func (S *Service) HandleInitTask(a app.IApp, task *app.InitTask) error
  • func (S *Service) HandleRemoteSendMessageTask(a app.IApp, task *RemoteSendMessageTask) error

Types

type Config

type Config struct {
	Name         string
	Address      string
	Ping         string
	PingInterval int64
	Options      map[string]interface{}
	Timeout      int64
}

type Counter

type Counter struct {
	Count       int64 `json:"count"`
	Interval    int64 `json:"interval"`
	MinInterval int64 `json:"minInterval"`
	MaxInterval int64 `json:"maxInterval"`
	Atime       int64 `json:"atime"`
	Duration    int64 `json:"duration"`
	Size        int64 `json:"size"`
}

type RemoteReceiveMessageTask

type RemoteReceiveMessageTask struct {
	app.Task
	Name    string
	Message kk.Message
}

type RemoteSendMessageTask

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

type Service

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

func (*Service) Handle

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

func (*Service) HandleInitTask

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

func (*Service) HandleRemoteSendMessageTask

func (S *Service) HandleRemoteSendMessageTask(a app.IApp, task *RemoteSendMessageTask) error