entity

Documentation

Index

• type Address
  • func NewAddress(opts *AddressOptions) (res *Address)
  • func NewAddressFromString(address string) (res *Address, err error)
  • func (a *Address) IsEmpty() (res bool)
  • func (a *Address) String() (res string)
  • func (a *Address) Value() (res interface{})
• type AddressOptions
• type Result
  • func (r *Result) GetTaskId() (id primitive.ObjectID)
  • func (r *Result) SetTaskId(id primitive.ObjectID)
• type StreamMessageTaskData
• type TaskMessage
  • func (m *TaskMessage) ToString() (string, error)
• type TaskRunOptions

Types

type Address

type Address struct {
	Host string
	Port string
}

func NewAddress

func NewAddress(opts *AddressOptions) (res *Address)

func NewAddressFromString

func NewAddressFromString(address string) (res *Address, err error)

func (*Address) IsEmpty

func (a *Address) IsEmpty() (res bool)

func (*Address) String

func (a *Address) String() (res string)

func (*Address) Value

func (a *Address) Value() (res interface{})

type AddressOptions

type AddressOptions struct {
	Host string
	Port string
}

type Result

type Result bson.M

func (*Result) GetTaskId

func (r *Result) GetTaskId() (id primitive.ObjectID)

func (*Result) SetTaskId

func (r *Result) SetTaskId(id primitive.ObjectID)

type StreamMessageTaskData

type StreamMessageTaskData struct {
	TaskId  primitive.ObjectID `json:"task_id"`
	Records []interface{}      `json:"data"`
	Logs    []string           `json:"logs"`
}

type TaskMessage

type TaskMessage struct {
	Id    primitive.ObjectID `json:"id"`
	Key   string             `json:"key"`
	Cmd   string             `json:"cmd"`
	Param string             `json:"param"`
}

func (*TaskMessage) ToString

func (m *TaskMessage) ToString() (string, error)

type TaskRunOptions

type TaskRunOptions struct {
}