entity

package
v0.0.0-...-2f702e8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 15, 2022 License: BSD-3-Clause Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 {
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL