Documentation ¶
Index ¶
- Constants
- type AddAttributeMsg
- type AddColonyMsg
- type AddCronMsg
- type AddGeneratorMsg
- type AddRuntimeMsg
- type ApproveRuntimeRPC
- type AssignProcessMsg
- type CloseFailedMsg
- type CloseSuccessfulMsg
- type DeleteAllProcessGraphsMsg
- type DeleteAllProcessesMsg
- type DeleteColonyMsg
- type DeleteCronMsg
- type DeleteGeneratorMsg
- type DeleteProcessGraphMsg
- type DeleteProcessMsg
- type DeleteRuntimeMsg
- type GetAttributeMsg
- type GetClusterMsg
- type GetColoniesMsg
- type GetColonyMsg
- type GetColonyStatisticsMsg
- type GetCronMsg
- type GetCronsMsg
- type GetGeneratorMsg
- type GetGeneratorsMsg
- type GetProcessGraphMsg
- type GetProcessGraphsMsg
- type GetProcessHistMsg
- type GetProcessMsg
- type GetProcessesMsg
- type GetRuntimeMsg
- type GetRuntimesMsg
- type GetStatisticsMsg
- type PackGeneratorMsg
- type RPCMsg
- type RPCReplyMsg
- type RejectRuntimeMsg
- type ResolveGeneratorMsg
- type RunCronMsg
- type SubmitProcessSpecMsg
- type SubmitWorkflowSpecMsg
- type SubscribeProcessMsg
- type SubscribeProcessesMsg
- type VersionMsg
Constants ¶
View Source
const AddAttributePayloadType = "addattributemsg"
View Source
const AddColonyPayloadType = "addcolonymsg"
View Source
const AddCronPayloadType = "addcronmsg"
View Source
const AddGeneratorPayloadType = "addgeneratormsg"
View Source
const AddRuntimePayloadType = "addruntimemsg"
View Source
const ApproveRuntimePayloadType = "approveruntimemsg"
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 DeleteGeneratorPayloadType = "deletegeneratormsg"
View Source
const DeleteProcessGraphPayloadType = "deleteprocessgraphmsg"
View Source
const DeleteProcessPayloadType = "deleteprocessmsg"
View Source
const DeleteRuntimePayloadType = "deleteruntimemsg"
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 GetGeneratorPayloadType = "getgeneratormsg"
View Source
const GetGeneratorsPayloadType = "getgeneratorsmsg"
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 GetRuntimePayloadType = "getruntimemsg"
View Source
const GetRuntimesPayloadType = "getruntimesmsg"
View Source
const GetStatisiticsPayloadType = "getstatisticsmsg"
View Source
const PackGeneratorPayloadType = "packgeneratormsg"
View Source
const RejectRuntimePayloadType = "rejectruntimemsg"
View Source
const ResolveGeneratorPayloadType = "resolvegeneratormsg"
View Source
const RunCronPayloadType = "runcronmsg"
View Source
const SubmitProcessSpecPayloadType = "submitprocessespecmsg"
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 AddColonyMsg ¶
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 ¶
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 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 AddRuntimeMsg ¶
type AddRuntimeMsg struct { Runtime *core.Runtime `json:"runtime"` MsgType string `json:"msgtype"` }
func CreateAddRuntimeMsg ¶
func CreateAddRuntimeMsg(runtime *core.Runtime) *AddRuntimeMsg
func CreateAddRuntimeMsgFromJSON ¶
func CreateAddRuntimeMsgFromJSON(jsonString string) (*AddRuntimeMsg, error)
func (*AddRuntimeMsg) Equals ¶
func (msg *AddRuntimeMsg) Equals(msg2 *AddRuntimeMsg) bool
func (*AddRuntimeMsg) ToJSON ¶
func (msg *AddRuntimeMsg) ToJSON() (string, error)
func (*AddRuntimeMsg) ToJSONIndent ¶
func (msg *AddRuntimeMsg) ToJSONIndent() (string, error)
type ApproveRuntimeRPC ¶
type ApproveRuntimeRPC struct { RuntimeID string `json:"runtimeid"` MsgType string `json:"msgtype"` }
func CreateApproveRuntimeMsg ¶
func CreateApproveRuntimeMsg(runtimeID string) *ApproveRuntimeRPC
func CreateApproveRuntimeMsgFromJSON ¶
func CreateApproveRuntimeMsgFromJSON(jsonString string) (*ApproveRuntimeRPC, error)
func (*ApproveRuntimeRPC) Equals ¶
func (msg *ApproveRuntimeRPC) Equals(msg2 *ApproveRuntimeRPC) bool
func (*ApproveRuntimeRPC) ToJSON ¶
func (msg *ApproveRuntimeRPC) ToJSON() (string, error)
func (*ApproveRuntimeRPC) ToJSONIndent ¶
func (msg *ApproveRuntimeRPC) ToJSONIndent() (string, error)
type AssignProcessMsg ¶
type AssignProcessMsg struct { ColonyID string `json:"colonyid"` Latest bool `json:"latest"` 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 []string `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"` }
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"` }
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 ¶
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 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 DeleteRuntimeMsg ¶
type DeleteRuntimeMsg struct { RuntimeID string `json:"runtimeid"` MsgType string `json:"msgtype"` }
func CreateDeleteRuntimeMsg ¶
func CreateDeleteRuntimeMsg(runtimeID string) *DeleteRuntimeMsg
func CreateDeleteRuntimeMsgFromJSON ¶
func CreateDeleteRuntimeMsgFromJSON(jsonString string) (*DeleteRuntimeMsg, error)
func (*DeleteRuntimeMsg) Equals ¶
func (msg *DeleteRuntimeMsg) Equals(msg2 *DeleteRuntimeMsg) bool
func (*DeleteRuntimeMsg) ToJSON ¶
func (msg *DeleteRuntimeMsg) ToJSON() (string, error)
func (*DeleteRuntimeMsg) ToJSONIndent ¶
func (msg *DeleteRuntimeMsg) 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 ¶
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 ¶
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 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 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"` RuntimeID string `json:"runtimeid"` Seconds int `json:"seconds"` State int `json:"state"` MsgType string `json:"msgtype"` }
func CreateGetProcessHistMsg ¶
func CreateGetProcessHistMsg(colonyID string, runtimeID 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 ¶
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"` MsgType string `json:"msgtype"` }
func CreateGetProcessesMsg ¶
func CreateGetProcessesMsg(colonyID string, count int, state int) *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 GetRuntimeMsg ¶
func CreateGetRuntimeMsg ¶
func CreateGetRuntimeMsg(runtimeID string) *GetRuntimeMsg
func CreateGetRuntimeMsgFromJSON ¶
func CreateGetRuntimeMsgFromJSON(jsonString string) (*GetRuntimeMsg, error)
func (*GetRuntimeMsg) Equals ¶
func (msg *GetRuntimeMsg) Equals(msg2 *GetRuntimeMsg) bool
func (*GetRuntimeMsg) ToJSON ¶
func (msg *GetRuntimeMsg) ToJSON() (string, error)
func (*GetRuntimeMsg) ToJSONIndent ¶
func (msg *GetRuntimeMsg) ToJSONIndent() (string, error)
type GetRuntimesMsg ¶
func CreateGetRuntimesMsg ¶
func CreateGetRuntimesMsg(colonyID string) *GetRuntimesMsg
func CreateGetRuntimesMsgFromJSON ¶
func CreateGetRuntimesMsgFromJSON(jsonString string) (*GetRuntimesMsg, error)
func (*GetRuntimesMsg) Equals ¶
func (msg *GetRuntimesMsg) Equals(msg2 *GetRuntimesMsg) bool
func (*GetRuntimesMsg) ToJSON ¶
func (msg *GetRuntimesMsg) ToJSON() (string, error)
func (*GetRuntimesMsg) ToJSONIndent ¶
func (msg *GetRuntimesMsg) 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 CreateRPCMsg ¶
func CreateRPCMsgFromJSON ¶
func (*RPCMsg) DecodePayload ¶
func (*RPCMsg) ToJSONIndent ¶
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 RejectRuntimeMsg ¶
type RejectRuntimeMsg struct { RuntimeID string `json:"runtimeid"` MsgType string `json:"msgtype"` }
func CreateRejectRuntimeMsg ¶
func CreateRejectRuntimeMsg(runtimeID string) *RejectRuntimeMsg
func CreateRejectRuntimeMsgFromJSON ¶
func CreateRejectRuntimeMsgFromJSON(jsonString string) (*RejectRuntimeMsg, error)
func (*RejectRuntimeMsg) Equals ¶
func (msg *RejectRuntimeMsg) Equals(msg2 *RejectRuntimeMsg) bool
func (*RejectRuntimeMsg) ToJSON ¶
func (msg *RejectRuntimeMsg) ToJSON() (string, error)
func (*RejectRuntimeMsg) ToJSONIndent ¶
func (msg *RejectRuntimeMsg) 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 ¶
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 SubmitProcessSpecMsg ¶
type SubmitProcessSpecMsg struct { ProcessSpec *core.ProcessSpec `json:"spec"` MsgType string `json:"msgtype"` }
func CreateSubmitProcessSpecMsg ¶
func CreateSubmitProcessSpecMsg(processSpec *core.ProcessSpec) *SubmitProcessSpecMsg
func CreateSubmitProcessSpecMsgFromJSON ¶
func CreateSubmitProcessSpecMsgFromJSON(jsonString string) (*SubmitProcessSpecMsg, error)
func (*SubmitProcessSpecMsg) Equals ¶
func (msg *SubmitProcessSpecMsg) Equals(msg2 *SubmitProcessSpecMsg) bool
func (*SubmitProcessSpecMsg) ToJSON ¶
func (msg *SubmitProcessSpecMsg) ToJSON() (string, error)
func (*SubmitProcessSpecMsg) ToJSONIndent ¶
func (msg *SubmitProcessSpecMsg) 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"` RuntimeType string `json:"runtimetype"` State int `json:"state"` Timeout int `json:"timeout"` MsgType string `json:"msgtype"` }
func CreateSubscribeProcessMsg ¶
func CreateSubscribeProcessMsg(processID string, runtimeType 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 { RuntimeType string `json:"runtimetype"` State int `json:"state"` Timeout int `json:"timeout"` MsgType string `json:"msgtype"` }
func CreateSubscribeProcessesMsg ¶
func CreateSubscribeProcessesMsg(runtimeType 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 ¶
- add_attribute_msg.go
- add_colony_msg.go
- add_cron_msg.go
- add_generator_msg.go
- add_runtime_msg.go
- approve_runtime_msg.go
- assign_process_msg.go
- close_failed_msg.go
- close_successful_msg.go
- delete_all_processes_msg.go
- delete_all_processgraphs_msg.go
- delete_colony_msg.go
- delete_cron_msg.go
- delete_generator_msg.go
- delete_process_msg.go
- delete_processgraph_msg.go
- delete_runtime_msg.go
- get_attribute_msg.go
- get_cluster_msg.go
- get_colonies_msg.go
- get_colony_msg.go
- get_colony_statistics_msg.go
- get_cron_msg.go
- get_crons_msg.go
- get_generator_msg.go
- get_generators_msg.go
- get_process_hist.go
- get_process_msg.go
- get_processes_msg.go
- get_processgraph.go
- get_processgraphs.go
- get_runtime_msg.go
- get_runtimes_msg.go
- get_statistics_msg.go
- pack_generator.go
- reject_runtime_msg.go
- resolve_generator_msg.go
- rpc_msg.go
- rpc_reply_msg.go
- run_cron_msg.go
- submit_procspec_msg.go
- submit_workflow_spec.go
- subscribe_process_msg.go
- subscribe_processes_msg.go
- version_msg.go
Click to show internal directories.
Click to hide internal directories.