rpc

package
v1.0.0-alpha7 Latest Latest
Warning

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

Go to latest
Published: Oct 24, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

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

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 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 (*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 (*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 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 (*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

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 (*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 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

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"`
	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

type GetRuntimeMsg struct {
	RuntimeID string `json:"runtimeid"`
	MsgType   string `json:"msgtype"`
}

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

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

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

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 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 (*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 (*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)

Jump to

Keyboard shortcuts

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