rpc

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Aug 6, 2023 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const AddAttributePayloadType = "addattributemsg"
View Source 
const AddChildPayloadType = "addchildmsg"
View Source 
const AddColonyPayloadType = "addcolonymsg"
View Source 
const AddCronPayloadType = "addcronmsg"
View Source 
const AddExecutorPayloadType = "addexecutormsg"
View Source 
const AddFunctionPayloadType = "addfunctionmsg"
View Source 
const AddGeneratorPayloadType = "addgeneratormsg"
View Source 
const AddLogPayloadType = "addlogmsg"
View Source 
const ApproveExecutorPayloadType = "approveexecutormsg"
View Source 
const AssignProcessPayloadType = "assignprocessmsg"
View Source 
const CloseFailedPayloadType = "closefailedmsg"
View Source 
const CloseSuccessfulPayloadType = "closesuccessfulmsg"
View Source 
const DeleteAllProcessGraphsPayloadType = "deleteallprocessgraphsmsg"
View Source 
const DeleteAllProcessesPayloadType = "deleteallprocessesmsg"
View Source 
const DeleteColonyPayloadType = "deletecolonymsg"
View Source 
const DeleteCronPayloadType = "deletecronmsg"
View Source 
const DeleteExecutorPayloadType = "deleteexecutormsg"
View Source 
const DeleteFunctionPayloadType = "deletefunctionmsg"
View Source 
const DeleteGeneratorPayloadType = "deletegeneratormsg"
View Source 
const DeleteProcessGraphPayloadType = "deleteprocessgraphmsg"
View Source 
const DeleteProcessPayloadType = "deleteprocessmsg"
View Source 
const ErrorPayloadType = "error"
View Source 
const GetAttributePayloadType = "getattributemsg"
View Source 
const GetClusterPayloadType = "getclustermsg"
View Source 
const GetColoniesPayloadType = "getcoloniesmsg"
View Source 
const GetColonyPayloadType = "getcolonymsg"
View Source 
const GetColonyStatisticsPayloadType = "getcolonystatsmsg"
View Source 
const GetCronPayloadType = "getcronmsg"
View Source 
const GetCronsPayloadType = "getcronsmsg"
View Source 
const GetExecutorPayloadType = "getexecutormsg"
View Source 
const GetExecutorsPayloadType = "getexecutorsmsg"
View Source 
const GetFunctionsPayloadType = "getfunctionsmsg"
View Source 
const GetGeneratorPayloadType = "getgeneratormsg"
View Source 
const GetGeneratorsPayloadType = "getgeneratorsmsg"
View Source 
const GetLogsPayloadType = "getlogsmsg"
View Source 
const GetProcessGraphPayloadType = "getprocessgraphmsg"
View Source 
const GetProcessGraphsPayloadType = "getprocessgraphsmsg"
View Source 
const GetProcessHistPayloadType = "getprocesshistmsg"
View Source 
const GetProcessPayloadType = "getprocessmsg"
View Source 
const GetProcessesPayloadType = "getprocessesmsg"
View Source 
const GetStatisiticsPayloadType = "getstatisticsmsg"
View Source 
const PackGeneratorPayloadType = "packgeneratormsg"
View Source 
const RejectExecutorPayloadType = "rejectexecutormsg"
View Source 
const RenameColonyPayloadType = "renamecolonymsg"
View Source 
const ResetDatabasePayloadType = "resetdatabasemsg"
View Source 
const ResolveGeneratorPayloadType = "resolvegeneratormsg"
View Source 
const RunCronPayloadType = "runcronmsg"
View Source 
const SetOutputPayloadType = "setoutputmsg"
View Source 
const SubmitFunctionSpecPayloadType = "submitfuncspecmsg"
View Source 
const SubmitWorkflowSpecPayloadType = "submitworkflowspecmsg"
View Source 
const SubscribeProcessPayloadType = "subscribeprocessmsg"
View Source 
const SubscribeProcessesPayloadType = "subscribeprocessesmsg"
View Source 
const VersionPayloadType = "versionmsg"

Variables

This section is empty.

Functions

This section is empty.

Types

type AddAttributeMsg 

type AddAttributeMsg struct {
	Attribute core.Attribute `json:"attribute"`
	MsgType   string         `json:"msgtype"`
}

func CreateAddAttributeMsg 

func CreateAddAttributeMsg(attribute core.Attribute) *AddAttributeMsg

func CreateAddAttributeMsgFromJSON 

func CreateAddAttributeMsgFromJSON(jsonString string) (*AddAttributeMsg, error)

func (*AddAttributeMsg) Equals 

func (msg *AddAttributeMsg) Equals(msg2 *AddAttributeMsg) bool

func (*AddAttributeMsg) ToJSON 

func (msg *AddAttributeMsg) ToJSON() (string, error)

func (*AddAttributeMsg) ToJSONIndent 

func (msg *AddAttributeMsg) ToJSONIndent() (string, error)

type AddChildMsg 

type AddChildMsg struct {
	ProcessGraphID  string             `json:"processgraphid"`
	ParentProcessID string             `json:"parentprocessid"`
	ChildProcessID  string             `json:"childprocessid"`
	FunctionSpec    *core.FunctionSpec `json:"spec"`
	Insert          bool               `json:"insert"`
	MsgType         string             `json:"msgtype"`
}

func CreateAddChildMsg 

func CreateAddChildMsg(processGraphID string, parentProcessID string, childProcessID string, funcSpec *core.FunctionSpec, insert bool) *AddChildMsg

func CreateAddChildMsgFromJSON 

func CreateAddChildMsgFromJSON(jsonString string) (*AddChildMsg, error)

func (*AddChildMsg) Equals 

func (msg *AddChildMsg) Equals(msg2 *AddChildMsg) bool

func (*AddChildMsg) ToJSON 

func (msg *AddChildMsg) ToJSON() (string, error)

func (*AddChildMsg) ToJSONIndent 

func (msg *AddChildMsg) ToJSONIndent() (string, error)

type AddColonyMsg 

type AddColonyMsg struct {
	Colony  *core.Colony `json:"colony"`
	MsgType string       `json:"msgtype"`
}

func CreateAddColonyMsg 

func CreateAddColonyMsg(colony *core.Colony) *AddColonyMsg

func CreateAddColonyMsgFromJSON 

func CreateAddColonyMsgFromJSON(jsonString string) (*AddColonyMsg, error)

func (*AddColonyMsg) Equals 

func (msg *AddColonyMsg) Equals(msg2 *AddColonyMsg) bool

func (*AddColonyMsg) ToJSON 

func (msg *AddColonyMsg) ToJSON() (string, error)

func (*AddColonyMsg) ToJSONIndent 

func (msg *AddColonyMsg) ToJSONIndent() (string, error)

type AddCronMsg 

type AddCronMsg struct {
	Cron    *core.Cron `json:"cron"`
	MsgType string     `json:"msgtype"`
}

func CreateAddCronMsg 

func CreateAddCronMsg(cron *core.Cron) *AddCronMsg

func CreateAddCronMsgFromJSON 

func CreateAddCronMsgFromJSON(jsonString string) (*AddCronMsg, error)

func (*AddCronMsg) Equals 

func (msg *AddCronMsg) Equals(msg2 *AddCronMsg) bool

func (*AddCronMsg) ToJSON 

func (msg *AddCronMsg) ToJSON() (string, error)

func (*AddCronMsg) ToJSONIndent 

func (msg *AddCronMsg) ToJSONIndent() (string, error)

type AddExecutorMsg added in v1.0.1 

type AddExecutorMsg struct {
	Executor *core.Executor `json:"executor"`
	MsgType  string         `json:"msgtype"`
}

func CreateAddExecutorMsg added in v1.0.1 

func CreateAddExecutorMsg(executor *core.Executor) *AddExecutorMsg

func CreateAddExecutorMsgFromJSON added in v1.0.1 

func CreateAddExecutorMsgFromJSON(jsonString string) (*AddExecutorMsg, error)

func (*AddExecutorMsg) Equals added in v1.0.1 

func (msg *AddExecutorMsg) Equals(msg2 *AddExecutorMsg) bool

func (*AddExecutorMsg) ToJSON added in v1.0.1 

func (msg *AddExecutorMsg) ToJSON() (string, error)

func (*AddExecutorMsg) ToJSONIndent added in v1.0.1 

func (msg *AddExecutorMsg) ToJSONIndent() (string, error)

type AddFunctionMsg added in v1.0.1 

type AddFunctionMsg struct {
	Function *core.Function `json:"fun"`
	MsgType  string         `json:"msgtype"`
}

func CreateAddFunctionMsg added in v1.0.1 

func CreateAddFunctionMsg(function *core.Function) *AddFunctionMsg

func CreateAddFunctionMsgFromJSON added in v1.0.1 

func CreateAddFunctionMsgFromJSON(jsonString string) (*AddFunctionMsg, error)

func (*AddFunctionMsg) Equals added in v1.0.1 

func (msg *AddFunctionMsg) Equals(msg2 *AddFunctionMsg) bool

func (*AddFunctionMsg) ToJSON added in v1.0.1 

func (msg *AddFunctionMsg) ToJSON() (string, error)

func (*AddFunctionMsg) ToJSONIndent added in v1.0.1 

func (msg *AddFunctionMsg) ToJSONIndent() (string, error)

type AddGeneratorMsg 

type AddGeneratorMsg struct {
	Generator *core.Generator `json:"generator"`
	MsgType   string          `json:"msgtype"`
}

func CreateAddGeneratorMsg 

func CreateAddGeneratorMsg(generator *core.Generator) *AddGeneratorMsg

func CreateAddGeneratorMsgFromJSON 

func CreateAddGeneratorMsgFromJSON(jsonString string) (*AddGeneratorMsg, error)

func (*AddGeneratorMsg) Equals 

func (msg *AddGeneratorMsg) Equals(msg2 *AddGeneratorMsg) bool

func (*AddGeneratorMsg) ToJSON 

func (msg *AddGeneratorMsg) ToJSON() (string, error)

func (*AddGeneratorMsg) ToJSONIndent 

func (msg *AddGeneratorMsg) ToJSONIndent() (string, error)

type AddLogMsg added in v1.4.0 

type AddLogMsg struct {
	ProcessID string `json:"processid"`
	Message   string `json:"message"`
	MsgType   string `json:"msgtype"`
}

func CreateAddLogMsg added in v1.4.0 

func CreateAddLogMsg(processID string, logmsg string) *AddLogMsg

func CreateAddLogMsgFromJSON added in v1.4.0 

func CreateAddLogMsgFromJSON(jsonString string) (*AddLogMsg, error)

func (*AddLogMsg) Equals added in v1.4.0 

func (msg *AddLogMsg) Equals(msg2 *AddLogMsg) bool

func (*AddLogMsg) ToJSON added in v1.4.0 

func (msg *AddLogMsg) ToJSON() (string, error)

func (*AddLogMsg) ToJSONIndent added in v1.4.0 

func (msg *AddLogMsg) ToJSONIndent() (string, error)

type ApproveExecutorRPC added in v1.0.1 

type ApproveExecutorRPC struct {
	ExecutorID string `json:"executorid"`
	MsgType    string `json:"msgtype"`
}

func CreateApproveExecutorMsg added in v1.0.1 

func CreateApproveExecutorMsg(executorID string) *ApproveExecutorRPC

func CreateApproveExecutorMsgFromJSON added in v1.0.1 

func CreateApproveExecutorMsgFromJSON(jsonString string) (*ApproveExecutorRPC, error)

func (*ApproveExecutorRPC) Equals added in v1.0.1 

func (msg *ApproveExecutorRPC) Equals(msg2 *ApproveExecutorRPC) bool

func (*ApproveExecutorRPC) ToJSON added in v1.0.1 

func (msg *ApproveExecutorRPC) ToJSON() (string, error)

func (*ApproveExecutorRPC) ToJSONIndent added in v1.0.1 

func (msg *ApproveExecutorRPC) ToJSONIndent() (string, error)

type AssignProcessMsg 

type AssignProcessMsg struct {
	ColonyID string `json:"colonyid"`
	Latest   bool   `json:"latest"` // TODO: remove, not used anymore
	Timeout  int    `json:"timeout"`
	MsgType  string `json:"msgtype"`
}

func CreateAssignProcessMsg 

func CreateAssignProcessMsg(colonyID string) *AssignProcessMsg

func CreateAssignProcessMsgFromJSON 

func CreateAssignProcessMsgFromJSON(jsonString string) (*AssignProcessMsg, error)

func (*AssignProcessMsg) Equals 

func (msg *AssignProcessMsg) Equals(msg2 *AssignProcessMsg) bool

func (*AssignProcessMsg) ToJSON 

func (msg *AssignProcessMsg) ToJSON() (string, error)

func (*AssignProcessMsg) ToJSONIndent 

func (msg *AssignProcessMsg) ToJSONIndent() (string, error)

type CloseFailedMsg 

type CloseFailedMsg struct {
	ProcessID string   `json:"processid"`
	MsgType   string   `json:"msgtype"`
	Errors    []string `json:"errors"`
}

func CreateCloseFailedMsg 

func CreateCloseFailedMsg(processID string, errors []string) *CloseFailedMsg

func CreateCloseFailedMsgFromJSON 

func CreateCloseFailedMsgFromJSON(jsonString string) (*CloseFailedMsg, error)

func (*CloseFailedMsg) Equals 

func (msg *CloseFailedMsg) Equals(msg2 *CloseFailedMsg) bool

func (*CloseFailedMsg) ToJSON 

func (msg *CloseFailedMsg) ToJSON() (string, error)

func (*CloseFailedMsg) ToJSONIndent 

func (msg *CloseFailedMsg) ToJSONIndent() (string, error)

type CloseSuccessfulMsg 

type CloseSuccessfulMsg struct {
	ProcessID string        `json:"processid"`
	MsgType   string        `json:"msgtype"`
	Output    []interface{} `json:"out"`
}

func CreateCloseSuccessfulMsg 

func CreateCloseSuccessfulMsg(processID string) *CloseSuccessfulMsg

func CreateCloseSuccessfulMsgFromJSON 

func CreateCloseSuccessfulMsgFromJSON(jsonString string) (*CloseSuccessfulMsg, error)

func (*CloseSuccessfulMsg) Equals 

func (msg *CloseSuccessfulMsg) Equals(msg2 *CloseSuccessfulMsg) bool

func (*CloseSuccessfulMsg) ToJSON 

func (msg *CloseSuccessfulMsg) ToJSON() (string, error)

func (*CloseSuccessfulMsg) ToJSONIndent 

func (msg *CloseSuccessfulMsg) ToJSONIndent() (string, error)

type DeleteAllProcessGraphsMsg 

type DeleteAllProcessGraphsMsg struct {
	ColonyID string `json:"colonyid"`
	MsgType  string `json:"msgtype"`
	State    int    `json:"state"`
}

func CreateDeleteAllProcessGraphsMsg 

func CreateDeleteAllProcessGraphsMsg(colonyID string) *DeleteAllProcessGraphsMsg

func CreateDeleteAllProcessGraphsMsgFromJSON 

func CreateDeleteAllProcessGraphsMsgFromJSON(jsonString string) (*DeleteAllProcessGraphsMsg, error)

func (*DeleteAllProcessGraphsMsg) Equals 

func (msg *DeleteAllProcessGraphsMsg) Equals(msg2 *DeleteAllProcessGraphsMsg) bool

func (*DeleteAllProcessGraphsMsg) ToJSON 

func (msg *DeleteAllProcessGraphsMsg) ToJSON() (string, error)

func (*DeleteAllProcessGraphsMsg) ToJSONIndent 

func (msg *DeleteAllProcessGraphsMsg) ToJSONIndent() (string, error)

type DeleteAllProcessesMsg 

type DeleteAllProcessesMsg struct {
	ColonyID string `json:"colonyid"`
	MsgType  string `json:"msgtype"`
	State    int    `json:"state"`
}

func CreateDeleteAllProcessesMsg 

func CreateDeleteAllProcessesMsg(colonyID string) *DeleteAllProcessesMsg

func CreateDeleteAllProcessesMsgFromJSON 

func CreateDeleteAllProcessesMsgFromJSON(jsonString string) (*DeleteAllProcessesMsg, error)

func (*DeleteAllProcessesMsg) Equals 

func (msg *DeleteAllProcessesMsg) Equals(msg2 *DeleteAllProcessesMsg) bool

func (*DeleteAllProcessesMsg) ToJSON 

func (msg *DeleteAllProcessesMsg) ToJSON() (string, error)

func (*DeleteAllProcessesMsg) ToJSONIndent 

func (msg *DeleteAllProcessesMsg) ToJSONIndent() (string, error)

type DeleteColonyMsg 

type DeleteColonyMsg struct {
	ColonyID string `json:"colonyid"`
	MsgType  string `json:"msgtype"`
}

func CreateDeleteColonyMsg 

func CreateDeleteColonyMsg(colonyID string) *DeleteColonyMsg

func CreateDeleteColonyMsgFromJSON 

func CreateDeleteColonyMsgFromJSON(jsonString string) (*DeleteColonyMsg, error)

func (*DeleteColonyMsg) Equals 

func (msg *DeleteColonyMsg) Equals(msg2 *DeleteColonyMsg) bool

func (*DeleteColonyMsg) ToJSON 

func (msg *DeleteColonyMsg) ToJSON() (string, error)

func (*DeleteColonyMsg) ToJSONIndent 

func (msg *DeleteColonyMsg) ToJSONIndent() (string, error)

type DeleteCronMsg 

type DeleteCronMsg struct {
	CronID  string `json:"cronid"`
	MsgType string `json:"msgtype"`
	All     bool   `json:"all"`
}

func CreateDeleteCronMsg 

func CreateDeleteCronMsg(cronID string) *DeleteCronMsg

func CreateDeleteCronMsgFromJSON 

func CreateDeleteCronMsgFromJSON(jsonString string) (*DeleteCronMsg, error)

func (*DeleteCronMsg) Equals 

func (msg *DeleteCronMsg) Equals(msg2 *DeleteCronMsg) bool

func (*DeleteCronMsg) ToJSON 

func (msg *DeleteCronMsg) ToJSON() (string, error)

func (*DeleteCronMsg) ToJSONIndent 

func (msg *DeleteCronMsg) ToJSONIndent() (string, error)

type DeleteExecutorMsg added in v1.0.1 

type DeleteExecutorMsg struct {
	ExecutorID string `json:"executorid"`
	MsgType    string `json:"msgtype"`
}

func CreateDeleteExecutorMsg added in v1.0.1 

func CreateDeleteExecutorMsg(executorID string) *DeleteExecutorMsg

func CreateDeleteExecutorMsgFromJSON added in v1.0.1 

func CreateDeleteExecutorMsgFromJSON(jsonString string) (*DeleteExecutorMsg, error)

func (*DeleteExecutorMsg) Equals added in v1.0.1 

func (msg *DeleteExecutorMsg) Equals(msg2 *DeleteExecutorMsg) bool

func (*DeleteExecutorMsg) ToJSON added in v1.0.1 

func (msg *DeleteExecutorMsg) ToJSON() (string, error)

func (*DeleteExecutorMsg) ToJSONIndent added in v1.0.1 

func (msg *DeleteExecutorMsg) ToJSONIndent() (string, error)

type DeleteFunctionMsg added in v1.0.1 

type DeleteFunctionMsg struct {
	FunctionID string `json:"functionid"`
	MsgType    string `json:"msgtype"`
}

func CreateDeleteFunctionMsg added in v1.0.1 

func CreateDeleteFunctionMsg(functionID string) *DeleteFunctionMsg

func CreateDeleteFunctionMsgFromJSON added in v1.0.1 

func CreateDeleteFunctionMsgFromJSON(jsonString string) (*DeleteFunctionMsg, error)

func (*DeleteFunctionMsg) Equals added in v1.0.1 

func (msg *DeleteFunctionMsg) Equals(msg2 *DeleteFunctionMsg) bool

func (*DeleteFunctionMsg) ToJSON added in v1.0.1 

func (msg *DeleteFunctionMsg) ToJSON() (string, error)

func (*DeleteFunctionMsg) ToJSONIndent added in v1.0.1 

func (msg *DeleteFunctionMsg) ToJSONIndent() (string, error)

type DeleteGeneratorMsg 

type DeleteGeneratorMsg struct {
	GeneratorID string `json:"generatorid"`
	MsgType     string `json:"msgtype"`
	All         bool   `json:"all"`
}

func CreateDeleteGeneratorMsg 

func CreateDeleteGeneratorMsg(generatorID string) *DeleteGeneratorMsg

func CreateDeleteGeneratorMsgFromJSON 

func CreateDeleteGeneratorMsgFromJSON(jsonString string) (*DeleteGeneratorMsg, error)

func (*DeleteGeneratorMsg) Equals 

func (msg *DeleteGeneratorMsg) Equals(msg2 *DeleteGeneratorMsg) bool

func (*DeleteGeneratorMsg) ToJSON 

func (msg *DeleteGeneratorMsg) ToJSON() (string, error)

func (*DeleteGeneratorMsg) ToJSONIndent 

func (msg *DeleteGeneratorMsg) ToJSONIndent() (string, error)

type DeleteProcessGraphMsg 

type DeleteProcessGraphMsg struct {
	ProcessGraphID string `json:"processgraphid"`
	MsgType        string `json:"msgtype"`
	All            bool   `json:"all"`
}

func CreateDeleteProcessGraphMsg 

func CreateDeleteProcessGraphMsg(processGraphID string) *DeleteProcessGraphMsg

func CreateDeleteProcessGraphMsgFromJSON 

func CreateDeleteProcessGraphMsgFromJSON(jsonString string) (*DeleteProcessGraphMsg, error)

func (*DeleteProcessGraphMsg) Equals 

func (msg *DeleteProcessGraphMsg) Equals(msg2 *DeleteProcessGraphMsg) bool

func (*DeleteProcessGraphMsg) ToJSON 

func (msg *DeleteProcessGraphMsg) ToJSON() (string, error)

func (*DeleteProcessGraphMsg) ToJSONIndent 

func (msg *DeleteProcessGraphMsg) ToJSONIndent() (string, error)

type DeleteProcessMsg 

type DeleteProcessMsg struct {
	ProcessID string `json:"processid"`
	MsgType   string `json:"msgtype"`
	All       bool   `json:"all"`
}

func CreateDeleteProcessMsg 

func CreateDeleteProcessMsg(processID string) *DeleteProcessMsg

func CreateDeleteProcessMsgFromJSON 

func CreateDeleteProcessMsgFromJSON(jsonString string) (*DeleteProcessMsg, error)

func (*DeleteProcessMsg) Equals 

func (msg *DeleteProcessMsg) Equals(msg2 *DeleteProcessMsg) bool

func (*DeleteProcessMsg) ToJSON 

func (msg *DeleteProcessMsg) ToJSON() (string, error)

func (*DeleteProcessMsg) ToJSONIndent 

func (msg *DeleteProcessMsg) ToJSONIndent() (string, error)

type GetAttributeMsg 

type GetAttributeMsg struct {
	AttributeID string `json:"attributeid"`
	MsgType     string `json:"msgtype"`
}

func CreateGetAttributeMsg 

func CreateGetAttributeMsg(attributeID string) *GetAttributeMsg

func CreateGetAttributeMsgFromJSON 

func CreateGetAttributeMsgFromJSON(jsonString string) (*GetAttributeMsg, error)

func (*GetAttributeMsg) Equals 

func (msg *GetAttributeMsg) Equals(msg2 *GetAttributeMsg) bool

func (*GetAttributeMsg) ToJSON 

func (msg *GetAttributeMsg) ToJSON() (string, error)

func (*GetAttributeMsg) ToJSONIndent 

func (msg *GetAttributeMsg) ToJSONIndent() (string, error)

type GetClusterMsg 

type GetClusterMsg struct {
	MsgType string `json:"msgtype"`
}

func CreateGetClusterMsg 

func CreateGetClusterMsg() *GetClusterMsg

func CreateGetClusterMsgFromJSON 

func CreateGetClusterMsgFromJSON(jsonString string) (*GetClusterMsg, error)

func (*GetClusterMsg) Equals 

func (msg *GetClusterMsg) Equals(msg2 *GetClusterMsg) bool

func (*GetClusterMsg) ToJSON 

func (msg *GetClusterMsg) ToJSON() (string, error)

func (*GetClusterMsg) ToJSONIndent 

func (msg *GetClusterMsg) ToJSONIndent() (string, error)

type GetColoniesMsg 

type GetColoniesMsg struct {
	MsgType string `json:"msgtype"`
}

func CreateGetColoniesMsg 

func CreateGetColoniesMsg() *GetColoniesMsg

func CreateGetColoniesMsgFromJSON 

func CreateGetColoniesMsgFromJSON(jsonString string) (*GetColoniesMsg, error)

func (*GetColoniesMsg) Equals 

func (msg *GetColoniesMsg) Equals(msg2 *GetColoniesMsg) bool

func (*GetColoniesMsg) ToJSON 

func (msg *GetColoniesMsg) ToJSON() (string, error)

func (*GetColoniesMsg) ToJSONIndent 

func (msg *GetColoniesMsg) ToJSONIndent() (string, error)

type GetColonyMsg 

type GetColonyMsg struct {
	ColonyID string `json:"colonyid"`
	MsgType  string `json:"msgtype"`
}

func CreateGetColonyMsg 

func CreateGetColonyMsg(colonyID string) *GetColonyMsg

func CreateGetColonyMsgFromJSON 

func CreateGetColonyMsgFromJSON(jsonString string) (*GetColonyMsg, error)

func (*GetColonyMsg) Equals 

func (msg *GetColonyMsg) Equals(msg2 *GetColonyMsg) bool

func (*GetColonyMsg) ToJSON 

func (msg *GetColonyMsg) ToJSON() (string, error)

func (*GetColonyMsg) ToJSONIndent 

func (msg *GetColonyMsg) ToJSONIndent() (string, error)

type GetColonyStatisticsMsg 

type GetColonyStatisticsMsg struct {
	ColonyID string `json:"colonyid"`
	MsgType  string `json:"msgtype"`
}

func CreateGetColonyStatisticsMsg 

func CreateGetColonyStatisticsMsg(colonyID string) *GetColonyStatisticsMsg

func CreateGetColonyStatisticsMsgFromJSON 

func CreateGetColonyStatisticsMsgFromJSON(jsonString string) (*GetColonyStatisticsMsg, error)

func (*GetColonyStatisticsMsg) Equals 

func (msg *GetColonyStatisticsMsg) Equals(msg2 *GetColonyStatisticsMsg) bool

func (*GetColonyStatisticsMsg) ToJSON 

func (msg *GetColonyStatisticsMsg) ToJSON() (string, error)

func (*GetColonyStatisticsMsg) ToJSONIndent 

func (msg *GetColonyStatisticsMsg) ToJSONIndent() (string, error)

type GetCronMsg 

type GetCronMsg struct {
	CronID  string `json:"cronid"`
	MsgType string `json:"msgtype"`
}

func CreateGetCronMsg 

func CreateGetCronMsg(cronID string) *GetCronMsg

func CreateGetCronMsgFromJSON 

func CreateGetCronMsgFromJSON(jsonString string) (*GetCronMsg, error)

func (*GetCronMsg) Equals 

func (msg *GetCronMsg) Equals(msg2 *GetCronMsg) bool

func (*GetCronMsg) ToJSON 

func (msg *GetCronMsg) ToJSON() (string, error)

func (*GetCronMsg) ToJSONIndent 

func (msg *GetCronMsg) ToJSONIndent() (string, error)

type GetCronsMsg 

type GetCronsMsg struct {
	ColonyID string `json:"colonyid"`
	Count    int    `json:"count"`
	MsgType  string `json:"msgtype"`
}

func CreateGetCronsMsg 

func CreateGetCronsMsg(colonyID string, count int) *GetCronsMsg

func CreateGetCronsMsgFromJSON 

func CreateGetCronsMsgFromJSON(jsonString string) (*GetCronsMsg, error)

func (*GetCronsMsg) Equals 

func (msg *GetCronsMsg) Equals(msg2 *GetCronsMsg) bool

func (*GetCronsMsg) ToJSON 

func (msg *GetCronsMsg) ToJSON() (string, error)

func (*GetCronsMsg) ToJSONIndent 

func (msg *GetCronsMsg) ToJSONIndent() (string, error)

type GetExecutorMsg added in v1.0.1 

type GetExecutorMsg struct {
	ExecutorID string `json:"executorid"`
	MsgType    string `json:"msgtype"`
}

func CreateGetExecutorMsg added in v1.0.1 

func CreateGetExecutorMsg(executorID string) *GetExecutorMsg

func CreateGetExecutorMsgFromJSON added in v1.0.1 

func CreateGetExecutorMsgFromJSON(jsonString string) (*GetExecutorMsg, error)

func (*GetExecutorMsg) Equals added in v1.0.1 

func (msg *GetExecutorMsg) Equals(msg2 *GetExecutorMsg) bool

func (*GetExecutorMsg) ToJSON added in v1.0.1 

func (msg *GetExecutorMsg) ToJSON() (string, error)

func (*GetExecutorMsg) ToJSONIndent added in v1.0.1 

func (msg *GetExecutorMsg) ToJSONIndent() (string, error)

type GetExecutorsMsg added in v1.0.1 

type GetExecutorsMsg struct {
	ColonyID string `json:"colonyid"`
	MsgType  string `json:"msgtype"`
}

func CreateGetExecutorsMsg added in v1.0.1 

func CreateGetExecutorsMsg(colonyID string) *GetExecutorsMsg

func CreateGetExecutorsMsgFromJSON added in v1.0.1 

func CreateGetExecutorsMsgFromJSON(jsonString string) (*GetExecutorsMsg, error)

func (*GetExecutorsMsg) Equals added in v1.0.1 

func (msg *GetExecutorsMsg) Equals(msg2 *GetExecutorsMsg) bool

func (*GetExecutorsMsg) ToJSON added in v1.0.1 

func (msg *GetExecutorsMsg) ToJSON() (string, error)

func (*GetExecutorsMsg) ToJSONIndent added in v1.0.1 

func (msg *GetExecutorsMsg) ToJSONIndent() (string, error)

type GetFunctionsMsg added in v1.0.1 

type GetFunctionsMsg struct {
	ExecutorID string `json:"executorid"`
	ColonyID   string `json:"colonyid"`
	MsgType    string `json:"msgtype"`
}

func CreateGetFunctionsByColonyIDMsg added in v1.0.1 

func CreateGetFunctionsByColonyIDMsg(colonyID string) *GetFunctionsMsg

func CreateGetFunctionsByExecutorIDMsg added in v1.0.1 

func CreateGetFunctionsByExecutorIDMsg(executorID string) *GetFunctionsMsg

func CreateGetFunctionsMsgFromJSON added in v1.0.1 

func CreateGetFunctionsMsgFromJSON(jsonString string) (*GetFunctionsMsg, error)

func (*GetFunctionsMsg) Equals added in v1.0.1 

func (msg *GetFunctionsMsg) Equals(msg2 *GetFunctionsMsg) bool

func (*GetFunctionsMsg) ToJSON added in v1.0.1 

func (msg *GetFunctionsMsg) ToJSON() (string, error)

func (*GetFunctionsMsg) ToJSONIndent added in v1.0.1 

func (msg *GetFunctionsMsg) ToJSONIndent() (string, error)

type GetGeneratorMsg 

type GetGeneratorMsg struct {
	GeneratorID string `json:"generatorid"`
	MsgType     string `json:"msgtype"`
}

func CreateGetGeneratorMsg 

func CreateGetGeneratorMsg(generatorID string) *GetGeneratorMsg

func CreateGetGeneratorMsgFromJSON 

func CreateGetGeneratorMsgFromJSON(jsonString string) (*GetGeneratorMsg, error)

func (*GetGeneratorMsg) Equals 

func (msg *GetGeneratorMsg) Equals(msg2 *GetGeneratorMsg) bool

func (*GetGeneratorMsg) ToJSON 

func (msg *GetGeneratorMsg) ToJSON() (string, error)

func (*GetGeneratorMsg) ToJSONIndent 

func (msg *GetGeneratorMsg) ToJSONIndent() (string, error)

type GetGeneratorsMsg 

type GetGeneratorsMsg struct {
	ColonyID string `json:"colonyid"`
	Count    int    `json:"count"`
	MsgType  string `json:"msgtype"`
}

func CreateGetGeneratorsMsg 

func CreateGetGeneratorsMsg(colonyID string, count int) *GetGeneratorsMsg

func CreateGetGeneratorsMsgFromJSON 

func CreateGetGeneratorsMsgFromJSON(jsonString string) (*GetGeneratorsMsg, error)

func (*GetGeneratorsMsg) Equals 

func (msg *GetGeneratorsMsg) Equals(msg2 *GetGeneratorsMsg) bool

func (*GetGeneratorsMsg) ToJSON 

func (msg *GetGeneratorsMsg) ToJSON() (string, error)

func (*GetGeneratorsMsg) ToJSONIndent 

func (msg *GetGeneratorsMsg) ToJSONIndent() (string, error)

type GetLogsMsg added in v1.4.0 

type GetLogsMsg struct {
	ProcessID  string `json:"processid"`
	ExecutorID string `json:"executorid"`
	Count      int    `json:"count"`
	Since      int64  `json:"since"`
	MsgType    string `json:"msgtype"`
}

func CreateGetLogsMsg added in v1.4.0 

func CreateGetLogsMsg(processID string, count int, since int64) *GetLogsMsg

func CreateGetLogsMsgFromJSON added in v1.4.0 

func CreateGetLogsMsgFromJSON(jsonString string) (*GetLogsMsg, error)

func (*GetLogsMsg) Equals added in v1.4.0 

func (msg *GetLogsMsg) Equals(msg2 *GetLogsMsg) bool

func (*GetLogsMsg) ToJSON added in v1.4.0 

func (msg *GetLogsMsg) ToJSON() (string, error)

func (*GetLogsMsg) ToJSONIndent added in v1.4.0 

func (msg *GetLogsMsg) ToJSONIndent() (string, error)

type GetProcessGraphMsg 

type GetProcessGraphMsg struct {
	ProcessGraphID string `json:"processgraphid"`
	MsgType        string `json:"msgtype"`
}

func CreateGetProcessGraphMsg 

func CreateGetProcessGraphMsg(processGraphID string) *GetProcessGraphMsg

func CreateGetProcessGraphMsgFromJSON 

func CreateGetProcessGraphMsgFromJSON(jsonString string) (*GetProcessGraphMsg, error)

func (*GetProcessGraphMsg) Equals 

func (msg *GetProcessGraphMsg) Equals(msg2 *GetProcessGraphMsg) bool

func (*GetProcessGraphMsg) ToJSON 

func (msg *GetProcessGraphMsg) ToJSON() (string, error)

func (*GetProcessGraphMsg) ToJSONIndent 

func (msg *GetProcessGraphMsg) ToJSONIndent() (string, error)

type GetProcessGraphsMsg 

type GetProcessGraphsMsg struct {
	ColonyID string `json:"colonyid"`
	Count    int    `json:"count"`
	State    int    `json:"state"`
	MsgType  string `json:"msgtype"`
}

func CreateGetProcessGraphsMsg 

func CreateGetProcessGraphsMsg(colonyID string, count int, state int) *GetProcessGraphsMsg

func CreateGetProcessGraphsMsgFromJSON 

func CreateGetProcessGraphsMsgFromJSON(jsonString string) (*GetProcessGraphsMsg, error)

func (*GetProcessGraphsMsg) Equals 

func (msg *GetProcessGraphsMsg) Equals(msg2 *GetProcessGraphsMsg) bool

func (*GetProcessGraphsMsg) ToJSON 

func (msg *GetProcessGraphsMsg) ToJSON() (string, error)

func (*GetProcessGraphsMsg) ToJSONIndent 

func (msg *GetProcessGraphsMsg) ToJSONIndent() (string, error)

type GetProcessHistMsg 

type GetProcessHistMsg struct {
	ColonyID   string `json:"colonyid"`
	ExecutorID string `json:"executorid"`
	Seconds    int    `json:"seconds"`
	State      int    `json:"state"`
	MsgType    string `json:"msgtype"`
}

func CreateGetProcessHistMsg 

func CreateGetProcessHistMsg(colonyID string, executorID string, seconds int, state int) *GetProcessHistMsg

func CreateGetProcessHistMsgFromJSON 

func CreateGetProcessHistMsgFromJSON(jsonString string) (*GetProcessHistMsg, error)

func (*GetProcessHistMsg) Equals 

func (msg *GetProcessHistMsg) Equals(msg2 *GetProcessHistMsg) bool

func (*GetProcessHistMsg) ToJSON 

func (msg *GetProcessHistMsg) ToJSON() (string, error)

func (*GetProcessHistMsg) ToJSONIndent 

func (msg *GetProcessHistMsg) ToJSONIndent() (string, error)

type GetProcessMsg 

type GetProcessMsg struct {
	ProcessID string `json:"processid"`
	MsgType   string `json:"msgtype"`
}

func CreateGetProcessMsg 

func CreateGetProcessMsg(processID string) *GetProcessMsg

func CreateGetProcessMsgFromJSON 

func CreateGetProcessMsgFromJSON(jsonString string) (*GetProcessMsg, error)

func (*GetProcessMsg) Equals 

func (msg *GetProcessMsg) Equals(msg2 *GetProcessMsg) bool

func (*GetProcessMsg) ToJSON 

func (msg *GetProcessMsg) ToJSON() (string, error)

func (*GetProcessMsg) ToJSONIndent 

func (msg *GetProcessMsg) ToJSONIndent() (string, error)

type GetProcessesMsg 

type GetProcessesMsg struct {
	ColonyID     string `json:"colonyid"`
	Count        int    `json:"count"`
	State        int    `json:"state"`
	ExecutorType string `json:"executortype"`
	MsgType      string `json:"msgtype"`
}

func CreateGetProcessesMsg 

func CreateGetProcessesMsg(colonyID string, count int, state int, executorType string) *GetProcessesMsg

func CreateGetProcessesMsgFromJSON 

func CreateGetProcessesMsgFromJSON(jsonString string) (*GetProcessesMsg, error)

func (*GetProcessesMsg) Equals 

func (msg *GetProcessesMsg) Equals(msg2 *GetProcessesMsg) bool

func (*GetProcessesMsg) ToJSON 

func (msg *GetProcessesMsg) ToJSON() (string, error)

func (*GetProcessesMsg) ToJSONIndent 

func (msg *GetProcessesMsg) ToJSONIndent() (string, error)

type GetStatisticsMsg 

type GetStatisticsMsg struct {
	MsgType string `json:"msgtype"`
}

func CreateGetStatisticsMsg 

func CreateGetStatisticsMsg() *GetStatisticsMsg

func CreateGetStatisticsMsgFromJSON 

func CreateGetStatisticsMsgFromJSON(jsonString string) (*GetStatisticsMsg, error)

func (*GetStatisticsMsg) Equals 

func (msg *GetStatisticsMsg) Equals(msg2 *GetStatisticsMsg) bool

func (*GetStatisticsMsg) ToJSON 

func (msg *GetStatisticsMsg) ToJSON() (string, error)

func (*GetStatisticsMsg) ToJSONIndent 

func (msg *GetStatisticsMsg) ToJSONIndent() (string, error)

type PackGeneratorMsg 

type PackGeneratorMsg struct {
	GeneratorID string `json:"generatorid"`
	Arg         string `json:"arg"`
	MsgType     string `json:"msgtype"`
}

func CreatePackGeneratorMsg 

func CreatePackGeneratorMsg(generatorID string, arg string) *PackGeneratorMsg

func CreatePackGeneratorMsgFromJSON 

func CreatePackGeneratorMsgFromJSON(jsonString string) (*PackGeneratorMsg, error)

func (*PackGeneratorMsg) Equals 

func (msg *PackGeneratorMsg) Equals(msg2 *PackGeneratorMsg) bool

func (*PackGeneratorMsg) ToJSON 

func (msg *PackGeneratorMsg) ToJSON() (string, error)

func (*PackGeneratorMsg) ToJSONIndent 

func (msg *PackGeneratorMsg) ToJSONIndent() (string, error)

type RPCMsg 

type RPCMsg struct {
	Signature   string `json:"signature"`
	PayloadType string `json:"payloadtype"`
	Payload     string `json:"payload"`
}

func CreateInsecureRPCMsg 

func CreateInsecureRPCMsg(payloadType string, payload string) (*RPCMsg, error)

func CreateRPCMsg 

func CreateRPCMsg(payloadType string, payload string, prvKey string) (*RPCMsg, error)

func CreateRPCMsgFromJSON 

func CreateRPCMsgFromJSON(jsonString string) (*RPCMsg, error)

func (*RPCMsg) DecodePayload 

func (msg *RPCMsg) DecodePayload() string

func (*RPCMsg) Equals 

func (msg *RPCMsg) Equals(msg2 *RPCMsg) bool

func (*RPCMsg) ToJSON 

func (msg *RPCMsg) ToJSON() (string, error)

func (*RPCMsg) ToJSONIndent 

func (msg *RPCMsg) ToJSONIndent() (string, error)

type RPCReplyMsg 

type RPCReplyMsg struct {
	PayloadType string `json:"payloadtype"`
	Payload     string `json:"payload"`
	Error       bool   `json:"error"`
}

func CreateRPCErrorReplyMsg 

func CreateRPCErrorReplyMsg(payloadType string, payload string) (*RPCReplyMsg, error)

func CreateRPCReplyMsg 

func CreateRPCReplyMsg(payloadType string, payload string) (*RPCReplyMsg, error)

func CreateRPCReplyMsgFromJSON 

func CreateRPCReplyMsgFromJSON(jsonString string) (*RPCReplyMsg, error)

func (*RPCReplyMsg) DecodePayload 

func (msg *RPCReplyMsg) DecodePayload() string

func (*RPCReplyMsg) Equals 

func (msg *RPCReplyMsg) Equals(msg2 *RPCReplyMsg) bool

func (*RPCReplyMsg) ToJSON 

func (msg *RPCReplyMsg) ToJSON() (string, error)

func (*RPCReplyMsg) ToJSONIndent 

func (msg *RPCReplyMsg) ToJSONIndent() (string, error)

type RejectExecutorMsg added in v1.0.1 

type RejectExecutorMsg struct {
	ExecutorID string `json:"executorid"`
	MsgType    string `json:"msgtype"`
}

func CreateRejectExecutorMsg added in v1.0.1 

func CreateRejectExecutorMsg(executorID string) *RejectExecutorMsg

func CreateRejectExecutorMsgFromJSON added in v1.0.1 

func CreateRejectExecutorMsgFromJSON(jsonString string) (*RejectExecutorMsg, error)

func (*RejectExecutorMsg) Equals added in v1.0.1 

func (msg *RejectExecutorMsg) Equals(msg2 *RejectExecutorMsg) bool

func (*RejectExecutorMsg) ToJSON added in v1.0.1 

func (msg *RejectExecutorMsg) ToJSON() (string, error)

func (*RejectExecutorMsg) ToJSONIndent added in v1.0.1 

func (msg *RejectExecutorMsg) ToJSONIndent() (string, error)

type RenameColonyMsg added in v1.1.0 

type RenameColonyMsg struct {
	ColonyID string `json:"colonyid"`
	Name     string `json:"name"`
	MsgType  string `json:"msgtype"`
}

func CreateRenameColonyMsg added in v1.1.0 

func CreateRenameColonyMsg(colonyID string, name string) *RenameColonyMsg

func CreateRenameColonyMsgFromJSON added in v1.1.0 

func CreateRenameColonyMsgFromJSON(jsonString string) (*RenameColonyMsg, error)

func (*RenameColonyMsg) Equals added in v1.1.0 

func (msg *RenameColonyMsg) Equals(msg2 *RenameColonyMsg) bool

func (*RenameColonyMsg) ToJSON added in v1.1.0 

func (msg *RenameColonyMsg) ToJSON() (string, error)

func (*RenameColonyMsg) ToJSONIndent added in v1.1.0 

func (msg *RenameColonyMsg) ToJSONIndent() (string, error)

type ResetDatabaseMsg 

type ResetDatabaseMsg struct {
	MsgType string `json:"msgtype"`
}

func CreateResetDatabaseMsg 

func CreateResetDatabaseMsg() *ResetDatabaseMsg

func CreateResetDatabaseMsgFromJSON 

func CreateResetDatabaseMsgFromJSON(jsonString string) (*ResetDatabaseMsg, error)

func (*ResetDatabaseMsg) Equals 

func (msg *ResetDatabaseMsg) Equals(msg2 *ResetDatabaseMsg) bool

func (*ResetDatabaseMsg) ToJSON 

func (msg *ResetDatabaseMsg) ToJSON() (string, error)

func (*ResetDatabaseMsg) ToJSONIndent 

func (msg *ResetDatabaseMsg) ToJSONIndent() (string, error)

type ResolveGeneratorMsg 

type ResolveGeneratorMsg struct {
	GeneratorName string `json:"generatorname"`
	MsgType       string `json:"msgtype"`
}

func CreateResolveGeneratorMsg 

func CreateResolveGeneratorMsg(generatorName string) *ResolveGeneratorMsg

func CreateResolveGeneratorMsgFromJSON 

func CreateResolveGeneratorMsgFromJSON(jsonString string) (*ResolveGeneratorMsg, error)

func (*ResolveGeneratorMsg) Equals 

func (msg *ResolveGeneratorMsg) Equals(msg2 *ResolveGeneratorMsg) bool

func (*ResolveGeneratorMsg) ToJSON 

func (msg *ResolveGeneratorMsg) ToJSON() (string, error)

func (*ResolveGeneratorMsg) ToJSONIndent 

func (msg *ResolveGeneratorMsg) ToJSONIndent() (string, error)

type RunCronMsg 

type RunCronMsg struct {
	CronID  string `json:"cronid"`
	MsgType string `json:"msgtype"`
}

func CreateRunCronMsg 

func CreateRunCronMsg(cronID string) *RunCronMsg

func CreateRunCronMsgFromJSON 

func CreateRunCronMsgFromJSON(jsonString string) (*RunCronMsg, error)

func (*RunCronMsg) Equals 

func (msg *RunCronMsg) Equals(msg2 *RunCronMsg) bool

func (*RunCronMsg) ToJSON 

func (msg *RunCronMsg) ToJSON() (string, error)

func (*RunCronMsg) ToJSONIndent 

func (msg *RunCronMsg) ToJSONIndent() (string, error)

type SetOutputMsg added in v1.4.0 

type SetOutputMsg struct {
	ProcessID string        `json:"processid"`
	MsgType   string        `json:"msgtype"`
	Output    []interface{} `json:"out"`
}

func CreateSetOutputMsg added in v1.4.0 

func CreateSetOutputMsg(processID string, output []interface{}) *SetOutputMsg

func CreateSetOutputMsgFromJSON added in v1.4.0 

func CreateSetOutputMsgFromJSON(jsonString string) (*SetOutputMsg, error)

func (*SetOutputMsg) Equals added in v1.4.0 

func (msg *SetOutputMsg) Equals(msg2 *SetOutputMsg) bool

func (*SetOutputMsg) ToJSON added in v1.4.0 

func (msg *SetOutputMsg) ToJSON() (string, error)

func (*SetOutputMsg) ToJSONIndent added in v1.4.0 

func (msg *SetOutputMsg) ToJSONIndent() (string, error)

type SubmitFunctionSpecMsg added in v1.0.1 

type SubmitFunctionSpecMsg struct {
	FunctionSpec *core.FunctionSpec `json:"spec"`
	MsgType      string             `json:"msgtype"`
}

func CreateSubmitFunctionSpecMsg added in v1.0.1 

func CreateSubmitFunctionSpecMsg(funcSpec *core.FunctionSpec) *SubmitFunctionSpecMsg

func CreateSubmitFunctionSpecMsgFromJSON added in v1.0.1 

func CreateSubmitFunctionSpecMsgFromJSON(jsonString string) (*SubmitFunctionSpecMsg, error)

func (*SubmitFunctionSpecMsg) Equals added in v1.0.1 

func (msg *SubmitFunctionSpecMsg) Equals(msg2 *SubmitFunctionSpecMsg) bool

func (*SubmitFunctionSpecMsg) ToJSON added in v1.0.1 

func (msg *SubmitFunctionSpecMsg) ToJSON() (string, error)

func (*SubmitFunctionSpecMsg) ToJSONIndent added in v1.0.1 

func (msg *SubmitFunctionSpecMsg) ToJSONIndent() (string, error)

type SubmitWorkflowSpecMsg 

type SubmitWorkflowSpecMsg struct {
	WorkflowSpec *core.WorkflowSpec `json:"spec"`
	MsgType      string             `json:"msgtype"`
}

func CreateSubmitWorkflowSpecMsg 

func CreateSubmitWorkflowSpecMsg(workflowSpec *core.WorkflowSpec) *SubmitWorkflowSpecMsg

func CreateSubmitWorkflowSpecMsgFromJSON 

func CreateSubmitWorkflowSpecMsgFromJSON(jsonString string) (*SubmitWorkflowSpecMsg, error)

func (*SubmitWorkflowSpecMsg) Equals 

func (msg *SubmitWorkflowSpecMsg) Equals(msg2 *SubmitWorkflowSpecMsg) bool

func (*SubmitWorkflowSpecMsg) ToJSON 

func (msg *SubmitWorkflowSpecMsg) ToJSON() (string, error)

func (*SubmitWorkflowSpecMsg) ToJSONIndent 

func (msg *SubmitWorkflowSpecMsg) ToJSONIndent() (string, error)

type SubscribeProcessMsg 

type SubscribeProcessMsg struct {
	ProcessID    string `json:"processid"`
	ExecutorType string `json:"executortype"`
	State        int    `json:"state"`
	Timeout      int    `json:"timeout"`
	MsgType      string `json:"msgtype"`
}

func CreateSubscribeProcessMsg 

func CreateSubscribeProcessMsg(processID string, executorType string, state int, timeout int) *SubscribeProcessMsg

func CreateSubscribeProcessMsgFromJSON 

func CreateSubscribeProcessMsgFromJSON(jsonString string) (*SubscribeProcessMsg, error)

func (*SubscribeProcessMsg) Equals 

func (msg *SubscribeProcessMsg) Equals(msg2 *SubscribeProcessMsg) bool

func (*SubscribeProcessMsg) ToJSON 

func (msg *SubscribeProcessMsg) ToJSON() (string, error)

func (*SubscribeProcessMsg) ToJSONIndent 

func (msg *SubscribeProcessMsg) ToJSONIndent() (string, error)

type SubscribeProcessesMsg 

type SubscribeProcessesMsg struct {
	ExecutorType string `json:"executortype"`
	State        int    `json:"state"`
	Timeout      int    `json:"timeout"`
	MsgType      string `json:"msgtype"`
}

func CreateSubscribeProcessesMsg 

func CreateSubscribeProcessesMsg(executorType string, state int, timeout int) *SubscribeProcessesMsg

func CreateSubscribeProcessesMsgFromJSON 

func CreateSubscribeProcessesMsgFromJSON(jsonString string) (*SubscribeProcessesMsg, error)

func (*SubscribeProcessesMsg) Equals 

func (msg *SubscribeProcessesMsg) Equals(msg2 *SubscribeProcessesMsg) bool

func (*SubscribeProcessesMsg) ToJSON 

func (msg *SubscribeProcessesMsg) ToJSON() (string, error)

func (*SubscribeProcessesMsg) ToJSONIndent 

func (msg *SubscribeProcessesMsg) ToJSONIndent() (string, error)

type VersionMsg 

type VersionMsg struct {
	BuildVersion string `json:"buildversion"`
	BuildTime    string `json:"buildtime"`
	MsgType      string `json:"msgtype"`
}

func CreateVersionMsg 

func CreateVersionMsg(buildVersion string, buildTime string) *VersionMsg

func CreateVersionMsgFromJSON 

func CreateVersionMsgFromJSON(jsonString string) (*VersionMsg, error)

func (*VersionMsg) Equals 

func (msg *VersionMsg) Equals(msg2 *VersionMsg) bool

func (*VersionMsg) ToJSON 

func (msg *VersionMsg) ToJSON() (string, error)

func (*VersionMsg) ToJSONIndent 

func (msg *VersionMsg) ToJSONIndent() (string, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.