rpc

package
v1.8.6 Latest Latest
Warning

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

 Go to latest Published: Jun 30, 2024 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 AddFilePayloadType = "addfilemsg"
View Source 
const AddFunctionPayloadType = "addfunctionmsg"
View Source 
const AddGeneratorPayloadType = "addgeneratormsg"
View Source 
const AddLogPayloadType = "addlogmsg"
View Source 
const AddUserPayloadType = "addusermsg"
View Source 
const ApproveExecutorPayloadType = "approveexecutormsg"
View Source 
const AssignProcessPayloadType = "assignprocessmsg"
View Source 
const ChangeColonyIDPayloadType = "changecolonyidmsg"
View Source 
const ChangeExecutorIDPayloadType = "changeexecutoridmsg"
View Source 
const ChangeServerIDPayloadType = "changeserveridmsg"
View Source 
const ChangeUserIDPayloadType = "changeuseridmsg"
View Source 
const CloseFailedPayloadType = "closefailedmsg"
View Source 
const CloseSuccessfulPayloadType = "closesuccessfulmsg"
View Source 
const CreateSnapshotPayloadType = "createsnapshotmsg"
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 GetFileLabelsPayloadType = "getfilelabelsmsg"
View Source 
const GetFilePayloadType = "getfilemsg"
View Source 
const GetFilesPayloadType = "getfilesmsg"
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 GetSnapshotPayloadType = "getsnapshotmsg"
View Source 
const GetSnapshotsPayloadType = "getsnapshotsmsg"
View Source 
const GetStatisiticsPayloadType = "getstatisticsmsg"
View Source 
const GetUserPayloadType = "getusermsg"
View Source 
const GetUsersPayloadType = "getusersmsg"
View Source 
const PackGeneratorPayloadType = "packgeneratormsg"
View Source 
const RejectExecutorPayloadType = "rejectexecutormsg"
View Source 
const RemoveAllProcessGraphsPayloadType = "removeallprocessgraphsmsg"
View Source 
const RemoveAllProcessesPayloadType = "removeallprocessesmsg"
View Source 
const RemoveAllSnapshotsPayloadType = "removeallsnapshotmsg"
View Source 
const RemoveColonyPayloadType = "removecolonymsg"
View Source 
const RemoveCronPayloadType = "removecronmsg"
View Source 
const RemoveExecutorPayloadType = "removeexecutormsg"
View Source 
const RemoveFilePayloadType = "removefilemsg"
View Source 
const RemoveFunctionPayloadType = "removefunctionmsg"
View Source 
const RemoveGeneratorPayloadType = "removegeneratormsg"
View Source 
const RemoveProcessGraphPayloadType = "removeprocessgraphmsg"
View Source 
const RemoveProcessPayloadType = "removeprocessmsg"
View Source 
const RemoveSnapshotPayloadType = "removesnapshotmsg"
View Source 
const RemoveUserPayloadType = "removeusermsg"
View Source 
const ReportAllocationsPayloadType = "reportallocationmsg"
View Source 
const ResolveGeneratorPayloadType = "resolvegeneratormsg"
View Source 
const RunCronPayloadType = "runcronmsg"
View Source 
const SearchLogsPayloadType = "searchlogsmsg"
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 AddFileMsg added in v1.5.0 

type AddFileMsg struct {
	File    *core.File `json:"file"`
	MsgType string     `json:"msgtype"`
}

func CreateAddFileMsg added in v1.5.0 

func CreateAddFileMsg(file *core.File) *AddFileMsg

func CreateAddFileMsgFromJSON added in v1.5.0 

func CreateAddFileMsgFromJSON(jsonString string) (*AddFileMsg, error)

func (*AddFileMsg) Equals added in v1.5.0 

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

func (*AddFileMsg) ToJSON added in v1.5.0 

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

func (*AddFileMsg) ToJSONIndent added in v1.5.0 

func (msg *AddFileMsg) 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 AddUserMsg added in v1.7.0 

type AddUserMsg struct {
	User    *core.User `json:"user"`
	MsgType string     `json:"msgtype"`
}

func CreateAddUserMsg added in v1.7.0 

func CreateAddUserMsg(user *core.User) *AddUserMsg

func CreateAddUserMsgFromJSON added in v1.7.0 

func CreateAddUserMsgFromJSON(jsonString string) (*AddUserMsg, error)

func (*AddUserMsg) Equals added in v1.7.0 

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

func (*AddUserMsg) ToJSON added in v1.7.0 

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

func (*AddUserMsg) ToJSONIndent added in v1.7.0 

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

type ApproveExecutorRPC added in v1.0.1 

type ApproveExecutorRPC struct {
	ColonyName   string `json:"colonyname"`
	ExecutorName string `json:"executorname"`
	MsgType      string `json:"msgtype"`
}

func CreateApproveExecutorMsg added in v1.0.1 

func CreateApproveExecutorMsg(colonyName string, executorName 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 {
	ColonyName      string `json:"colonyname"`
	Timeout         int    `json:"timeout"`
	AvailableCPU    string `json:"availablecpu"`
	AvailableMemory string `json:"availablemem"`
	MsgType         string `json:"msgtype"`
}

func CreateAssignProcessMsg 

func CreateAssignProcessMsg(colonyName string, availableCPU string, availableMemory 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 ChangeColonyIDMsg added in v1.7.7 

type ChangeColonyIDMsg struct {
	ColonyName string `json:"colonyname"`
	ColonyID   string `json:"colonyid"`
	MsgType    string `json:"msgtype"`
}

func CreateChangeColonyIDMsg added in v1.7.7 

func CreateChangeColonyIDMsg(colonyName, colonyID string) *ChangeColonyIDMsg

func CreateChangeColonyIDMsgFromJSON added in v1.7.7 

func CreateChangeColonyIDMsgFromJSON(jsonString string) (*ChangeColonyIDMsg, error)

func (*ChangeColonyIDMsg) Equals added in v1.7.7 

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

func (*ChangeColonyIDMsg) ToJSON added in v1.7.7 

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

func (*ChangeColonyIDMsg) ToJSONIndent added in v1.7.7 

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

type ChangeExecutorIDMsg added in v1.7.7 

type ChangeExecutorIDMsg struct {
	ColonyName string `json:"colonyname"`
	ExecutorID string `json:"executorid"`
	MsgType    string `json:"msgtype"`
}

func CreateChangeExecutorIDMsg added in v1.7.7 

func CreateChangeExecutorIDMsg(colonyName string, executorID string) *ChangeExecutorIDMsg

func CreateChangeExecutorIDMsgFromJSON added in v1.7.7 

func CreateChangeExecutorIDMsgFromJSON(jsonString string) (*ChangeExecutorIDMsg, error)

func (*ChangeExecutorIDMsg) Equals added in v1.7.7 

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

func (*ChangeExecutorIDMsg) ToJSON added in v1.7.7 

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

func (*ChangeExecutorIDMsg) ToJSONIndent added in v1.7.7 

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

type ChangeServerIDMsg added in v1.7.7 

type ChangeServerIDMsg struct {
	ServerID string `json:"serverid"`
	MsgType  string `json:"msgtype"`
}

func CreateChangeServerIDMsg added in v1.7.7 

func CreateChangeServerIDMsg(serverID string) *ChangeServerIDMsg

func CreateChangeServerIDMsgFromJSON added in v1.7.7 

func CreateChangeServerIDMsgFromJSON(jsonString string) (*ChangeServerIDMsg, error)

func (*ChangeServerIDMsg) Equals added in v1.7.7 

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

func (*ChangeServerIDMsg) ToJSON added in v1.7.7 

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

func (*ChangeServerIDMsg) ToJSONIndent added in v1.7.7 

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

type ChangeUserIDMsg added in v1.7.7 

type ChangeUserIDMsg struct {
	ColonyName string `json:"colonyname"`
	UserID     string `json:"userid"`
	MsgType    string `json:"msgtype"`
}

func CreateChangeUserIDMsg added in v1.7.7 

func CreateChangeUserIDMsg(colonyName, userID string) *ChangeUserIDMsg

func CreateChangeUserIDMsgFromJSON added in v1.7.7 

func CreateChangeUserIDMsgFromJSON(jsonString string) (*ChangeUserIDMsg, error)

func (*ChangeUserIDMsg) Equals added in v1.7.7 

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

func (*ChangeUserIDMsg) ToJSON added in v1.7.7 

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

func (*ChangeUserIDMsg) ToJSONIndent added in v1.7.7 

func (msg *ChangeUserIDMsg) 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 CreateSnapshotMsg added in v1.5.0 

type CreateSnapshotMsg struct {
	ColonyName string `json:"colonyname"`
	Label      string `json:"label"`
	Name       string `json:"name"`
	MsgType    string `json:"msgtype"`
}

func CreateCreateSnapshotMsg added in v1.5.0 

func CreateCreateSnapshotMsg(colonyName string, label string, name string) *CreateSnapshotMsg

func CreateCreateSnapshotMsgFromJSON added in v1.5.0 

func CreateCreateSnapshotMsgFromJSON(jsonString string) (*CreateSnapshotMsg, error)

func (*CreateSnapshotMsg) Equals added in v1.5.0 

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

func (*CreateSnapshotMsg) ToJSON added in v1.5.0 

func (msg *CreateSnapshotMsg) ToJSON() (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 {
	ColonyName string `json:"colonyname"`
	MsgType    string `json:"msgtype"`
}

func CreateGetColonyMsg 

func CreateGetColonyMsg(colonyName 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 {
	ColonyName string `json:"colonyname"`
	MsgType    string `json:"msgtype"`
}

func CreateGetColonyStatisticsMsg 

func CreateGetColonyStatisticsMsg(colonyName 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(cronName 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 {
	ColonyName string `json:"colonyname"`
	Count      int    `json:"count"`
	MsgType    string `json:"msgtype"`
}

func CreateGetCronsMsg 

func CreateGetCronsMsg(colonyName 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 {
	ColonyName   string `json:"colonyname"`
	ExecutorName string `json:"executorname"`
	MsgType      string `json:"msgtype"`
}

func CreateGetExecutorMsg added in v1.0.1 

func CreateGetExecutorMsg(colonyName string, executorName 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 {
	ColonyName string `json:"colonyname"`
	MsgType    string `json:"msgtype"`
}

func CreateGetExecutorsMsg added in v1.0.1 

func CreateGetExecutorsMsg(colonyName 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 GetFileLabelsMsg added in v1.5.0 

type GetFileLabelsMsg struct {
	MsgType    string `json:"msgtype"`
	ColonyName string `json:"colonyname"`
	Name       string `json:"name"`
	Exact      bool   `json:"exact"`
}

func CreateGetAllFileLabelsMsg added in v1.6.0 

func CreateGetAllFileLabelsMsg(colonyName string) *GetFileLabelsMsg

func CreateGetFileLabelsMsg added in v1.5.0 

func CreateGetFileLabelsMsg(colonyName string, name string, exact bool) *GetFileLabelsMsg

func CreateGetFileLabelsMsgFromJSON added in v1.5.0 

func CreateGetFileLabelsMsgFromJSON(jsonString string) (*GetFileLabelsMsg, error)

func (*GetFileLabelsMsg) Equals added in v1.5.0 

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

func (*GetFileLabelsMsg) ToJSON added in v1.5.0 

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

func (*GetFileLabelsMsg) ToJSONIndent added in v1.5.0 

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

type GetFileMsg added in v1.5.0 

type GetFileMsg struct {
	ColonyName string `json:"colonyname"`
	FileID     string `json:"fileid"`
	Label      string `json:"label"`
	Name       string `json:"name"`
	Latest     bool   `json:"latest"`
	MsgType    string `json:"msgtype"`
}

func CreateGetFileMsg added in v1.5.0 

func CreateGetFileMsg(colonyName string, fileID string, label string, name string, latest bool) *GetFileMsg

func CreateGetFileMsgFromJSON added in v1.5.0 

func CreateGetFileMsgFromJSON(jsonString string) (*GetFileMsg, error)

func (*GetFileMsg) Equals added in v1.5.0 

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

func (*GetFileMsg) ToJSON added in v1.5.0 

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

func (*GetFileMsg) ToJSONIndent added in v1.5.0 

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

type GetFilesMsg added in v1.5.0 

type GetFilesMsg struct {
	Label      string `json:"label"`
	ColonyName string `json:"colonyname"`
	MsgType    string `json:"msgtype"`
}

func CreateGetFilesMsg added in v1.5.0 

func CreateGetFilesMsg(colonyName string, label string) *GetFilesMsg

func CreateGetFilesMsgFromJSON added in v1.5.0 

func CreateGetFilesMsgFromJSON(jsonString string) (*GetFilesMsg, error)

func (*GetFilesMsg) Equals added in v1.5.0 

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

func (*GetFilesMsg) ToJSON added in v1.5.0 

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

func (*GetFilesMsg) ToJSONIndent added in v1.5.0 

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

type GetFunctionsMsg added in v1.0.1 

type GetFunctionsMsg struct {
	ExecutorName string `json:"executorname"`
	ColonyName   string `json:"colonyname"`
	MsgType      string `json:"msgtype"`
}

func CreateGetFunctionsByColonyNameMsg added in v1.7.0 

func CreateGetFunctionsByColonyNameMsg(colonyName string) *GetFunctionsMsg

func CreateGetFunctionsMsg added in v1.7.0 

func CreateGetFunctionsMsg(colonyName string, executorName 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 {
	ColonyName string `json:"colonyname"`
	Count      int    `json:"count"`
	MsgType    string `json:"msgtype"`
}

func CreateGetGeneratorsMsg 

func CreateGetGeneratorsMsg(colonyName 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 {
	ColonyName   string `json:"colonyname"`
	ProcessID    string `json:"processid"`
	ExecutorName string `json:"executorname"`
	Count        int    `json:"count"`
	Since        int64  `json:"since"`
	MsgType      string `json:"msgtype"`
}

func CreateGetLogsMsg added in v1.4.0 

func CreateGetLogsMsg(colonyName string, 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 {
	ColonyName string `json:"colonyname"`
	Count      int    `json:"count"`
	State      int    `json:"state"`
	MsgType    string `json:"msgtype"`
}

func CreateGetProcessGraphsMsg 

func CreateGetProcessGraphsMsg(colonyName 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 {
	ColonyName string `json:"colonyname"`
	ExecutorID string `json:"executorid"`
	Seconds    int    `json:"seconds"`
	State      int    `json:"state"`
	MsgType    string `json:"msgtype"`
}

func CreateGetProcessHistMsg 

func CreateGetProcessHistMsg(colonyName 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 {
	ColonyName   string `json:"colonyname"`
	Count        int    `json:"count"`
	State        int    `json:"state"`
	ExecutorType string `json:"executortype"`
	Label        string `json:"label"`
	Initiator    string `json:"initiator"`
	MsgType      string `json:"msgtype"`
}

func CreateGetProcessesMsg 

func CreateGetProcessesMsg(colonyName string, count int, state int, executorType string, label string, initiator 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 GetSnapshotMsg added in v1.5.0 

type GetSnapshotMsg struct {
	ColonyName string `json:"colonyname"`
	SnapshotID string `json:"snapshotid"`
	Name       string `json:"name"`
	MsgType    string `json:"msgtype"`
}

func CreateGetSnapshotMsg added in v1.5.0 

func CreateGetSnapshotMsg(colonyName string, snapshotID string, name string) *GetSnapshotMsg

func CreateGetSnapshotMsgFromJSON added in v1.5.0 

func CreateGetSnapshotMsgFromJSON(jsonString string) (*GetSnapshotMsg, error)

func (*GetSnapshotMsg) Equals added in v1.5.0 

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

func (*GetSnapshotMsg) ToJSON added in v1.5.0 

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

type GetSnapshotsMsg added in v1.5.0 

type GetSnapshotsMsg struct {
	ColonyName string `json:"colonyname"`
	MsgType    string `json:"msgtype"`
}

func CreateGetSnapshotsMsg added in v1.5.0 

func CreateGetSnapshotsMsg(colonyName string) *GetSnapshotsMsg

func CreateGetSnapshotsMsgFromJSON added in v1.5.0 

func CreateGetSnapshotsMsgFromJSON(jsonString string) (*GetSnapshotsMsg, error)

func (*GetSnapshotsMsg) Equals added in v1.5.0 

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

func (*GetSnapshotsMsg) ToJSON added in v1.5.0 

func (msg *GetSnapshotsMsg) ToJSON() (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 GetUserMsg added in v1.7.0 

type GetUserMsg struct {
	MsgType    string `json:"msgtype"`
	ColonyName string `json:"colonyname"`
	Name       string `json:"name"`
}

func CreateGetUserMsg added in v1.7.0 

func CreateGetUserMsg(colonyName string, name string) *GetUserMsg

func CreateGetUserMsgFromJSON added in v1.7.0 

func CreateGetUserMsgFromJSON(jsonString string) (*GetUserMsg, error)

func (*GetUserMsg) Equals added in v1.7.0 

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

func (*GetUserMsg) ToJSON added in v1.7.0 

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

func (*GetUserMsg) ToJSONIndent added in v1.7.0 

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

type GetUsersMsg added in v1.7.0 

type GetUsersMsg struct {
	MsgType    string `json:"msgtype"`
	ColonyName string `json:"colonyname"`
}

func CreateGetUsersMsg added in v1.7.0 

func CreateGetUsersMsg(colonyName string) *GetUsersMsg

func CreateGetUsersMsgFromJSON added in v1.7.0 

func CreateGetUsersMsgFromJSON(jsonString string) (*GetUsersMsg, error)

func (*GetUsersMsg) Equals added in v1.7.0 

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

func (*GetUsersMsg) ToJSON added in v1.7.0 

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

func (*GetUsersMsg) ToJSONIndent added in v1.7.0 

func (msg *GetUsersMsg) 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 {
	ColonyName   string `json:"colonyname"`
	ExecutorName string `json:"executorname"`
	MsgType      string `json:"msgtype"`
}

func CreateRejectExecutorMsg added in v1.0.1 

func CreateRejectExecutorMsg(colonyName string, executorName 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 RemoveAllProcessGraphsMsg added in v1.7.0 

type RemoveAllProcessGraphsMsg struct {
	ColonyName string `json:"colonyname"`
	MsgType    string `json:"msgtype"`
	State      int    `json:"state"`
}

func CreateRemoveAllProcessGraphsMsg added in v1.7.0 

func CreateRemoveAllProcessGraphsMsg(colonyName string) *RemoveAllProcessGraphsMsg

func CreateRemoveAllProcessGraphsMsgFromJSON added in v1.7.0 

func CreateRemoveAllProcessGraphsMsgFromJSON(jsonString string) (*RemoveAllProcessGraphsMsg, error)

func (*RemoveAllProcessGraphsMsg) Equals added in v1.7.0 

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

func (*RemoveAllProcessGraphsMsg) ToJSON added in v1.7.0 

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

func (*RemoveAllProcessGraphsMsg) ToJSONIndent added in v1.7.0 

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

type RemoveAllProcessesMsg added in v1.7.0 

type RemoveAllProcessesMsg struct {
	ColonyName string `json:"colonyname"`
	MsgType    string `json:"msgtype"`
	State      int    `json:"state"`
}

func CreateRemoveAllProcessesMsg added in v1.7.0 

func CreateRemoveAllProcessesMsg(colonyName string) *RemoveAllProcessesMsg

func CreateRemoveAllProcessesMsgFromJSON added in v1.7.0 

func CreateRemoveAllProcessesMsgFromJSON(jsonString string) (*RemoveAllProcessesMsg, error)

func (*RemoveAllProcessesMsg) Equals added in v1.7.0 

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

func (*RemoveAllProcessesMsg) ToJSON added in v1.7.0 

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

func (*RemoveAllProcessesMsg) ToJSONIndent added in v1.7.0 

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

type RemoveAllSnapshotsMsg added in v1.7.7 

type RemoveAllSnapshotsMsg struct {
	ColonyName string `json:"colonyname"`
	MsgType    string `json:"msgtype"`
}

func CreateRemoveAllSnapshotsMsg added in v1.7.7 

func CreateRemoveAllSnapshotsMsg(colonyName string) *RemoveAllSnapshotsMsg

func CreateRemoveAllSnapshotsMsgFromJSON added in v1.7.7 

func CreateRemoveAllSnapshotsMsgFromJSON(jsonString string) (*RemoveAllSnapshotsMsg, error)

func (*RemoveAllSnapshotsMsg) Equals added in v1.7.7 

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

func (*RemoveAllSnapshotsMsg) ToJSON added in v1.7.7 

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

type RemoveColonyMsg added in v1.7.0 

type RemoveColonyMsg struct {
	ColonyName string `json:"colonyname"`
	MsgType    string `json:"msgtype"`
}

func CreateRemoveColonyMsg added in v1.7.0 

func CreateRemoveColonyMsg(colonyName string) *RemoveColonyMsg

func CreateRemoveColonyMsgFromJSON added in v1.7.0 

func CreateRemoveColonyMsgFromJSON(jsonString string) (*RemoveColonyMsg, error)

func (*RemoveColonyMsg) Equals added in v1.7.0 

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

func (*RemoveColonyMsg) ToJSON added in v1.7.0 

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

func (*RemoveColonyMsg) ToJSONIndent added in v1.7.0 

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

type RemoveCronMsg added in v1.7.0 

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

func CreateRemoveCronMsg added in v1.7.0 

func CreateRemoveCronMsg(cronID string) *RemoveCronMsg

func CreateRemoveCronMsgFromJSON added in v1.7.0 

func CreateRemoveCronMsgFromJSON(jsonString string) (*RemoveCronMsg, error)

func (*RemoveCronMsg) Equals added in v1.7.0 

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

func (*RemoveCronMsg) ToJSON added in v1.7.0 

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

func (*RemoveCronMsg) ToJSONIndent added in v1.7.0 

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

type RemoveExecutorMsg added in v1.7.0 

type RemoveExecutorMsg struct {
	ColonyName   string `json:"colonyname"`
	ExecutorName string `json:"executorname"`
	MsgType      string `json:"msgtype"`
}

func CreateRemoveExecutorMsg added in v1.7.0 

func CreateRemoveExecutorMsg(colonyName string, executorName string) *RemoveExecutorMsg

func CreateRemoveExecutorMsgFromJSON added in v1.7.0 

func CreateRemoveExecutorMsgFromJSON(jsonString string) (*RemoveExecutorMsg, error)

func (*RemoveExecutorMsg) Equals added in v1.7.0 

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

func (*RemoveExecutorMsg) ToJSON added in v1.7.0 

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

func (*RemoveExecutorMsg) ToJSONIndent added in v1.7.0 

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

type RemoveFileMsg added in v1.7.0 

type RemoveFileMsg struct {
	MsgType    string `json:"msgtype"`
	ColonyName string `json:"colonyname"`
	FileID     string `json:"fileid"`
	Label      string `json:"label"`
	Name       string `json:"name"`
}

func CreateRemoveFileMsg added in v1.7.0 

func CreateRemoveFileMsg(colonyName string, fileID string, label string, name string) *RemoveFileMsg

func CreateRemoveFileMsgFromJSON added in v1.7.0 

func CreateRemoveFileMsgFromJSON(jsonString string) (*RemoveFileMsg, error)

func (*RemoveFileMsg) Equals added in v1.7.0 

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

func (*RemoveFileMsg) ToJSON added in v1.7.0 

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

func (*RemoveFileMsg) ToJSONIndent added in v1.7.0 

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

type RemoveFunctionMsg added in v1.7.0 

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

func CreateRemoveFunctionMsg added in v1.7.0 

func CreateRemoveFunctionMsg(functionID string) *RemoveFunctionMsg

func CreateRemoveFunctionMsgFromJSON added in v1.7.0 

func CreateRemoveFunctionMsgFromJSON(jsonString string) (*RemoveFunctionMsg, error)

func (*RemoveFunctionMsg) Equals added in v1.7.0 

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

func (*RemoveFunctionMsg) ToJSON added in v1.7.0 

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

func (*RemoveFunctionMsg) ToJSONIndent added in v1.7.0 

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

type RemoveGeneratorMsg added in v1.7.0 

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

func CreateRemoveGeneratorMsg added in v1.7.0 

func CreateRemoveGeneratorMsg(generatorID string) *RemoveGeneratorMsg

func CreateRemoveGeneratorMsgFromJSON added in v1.7.0 

func CreateRemoveGeneratorMsgFromJSON(jsonString string) (*RemoveGeneratorMsg, error)

func (*RemoveGeneratorMsg) Equals added in v1.7.0 

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

func (*RemoveGeneratorMsg) ToJSON added in v1.7.0 

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

func (*RemoveGeneratorMsg) ToJSONIndent added in v1.7.0 

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

type RemoveProcessGraphMsg added in v1.7.0 

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

func CreateRemoveProcessGraphMsg added in v1.7.0 

func CreateRemoveProcessGraphMsg(processGraphID string) *RemoveProcessGraphMsg

func CreateRemoveProcessGraphMsgFromJSON added in v1.7.0 

func CreateRemoveProcessGraphMsgFromJSON(jsonString string) (*RemoveProcessGraphMsg, error)

func (*RemoveProcessGraphMsg) Equals added in v1.7.0 

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

func (*RemoveProcessGraphMsg) ToJSON added in v1.7.0 

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

func (*RemoveProcessGraphMsg) ToJSONIndent added in v1.7.0 

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

type RemoveProcessMsg added in v1.7.0 

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

func CreateRemoveProcessMsg added in v1.7.0 

func CreateRemoveProcessMsg(processID string) *RemoveProcessMsg

func CreateRemoveProcessMsgFromJSON added in v1.7.0 

func CreateRemoveProcessMsgFromJSON(jsonString string) (*RemoveProcessMsg, error)

func (*RemoveProcessMsg) Equals added in v1.7.0 

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

func (*RemoveProcessMsg) ToJSON added in v1.7.0 

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

func (*RemoveProcessMsg) ToJSONIndent added in v1.7.0 

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

type RemoveSnapshotMsg added in v1.7.0 

type RemoveSnapshotMsg struct {
	ColonyName string `json:"colonyname"`
	SnapshotID string `json:"snapshotid"`
	Name       string `json:"name"`
	MsgType    string `json:"msgtype"`
}

func CreateRemoveSnapshotMsg added in v1.7.0 

func CreateRemoveSnapshotMsg(colonyName string, snapshotID string, name string) *RemoveSnapshotMsg

func CreateRemoveSnapshotMsgFromJSON added in v1.7.0 

func CreateRemoveSnapshotMsgFromJSON(jsonString string) (*RemoveSnapshotMsg, error)

func (*RemoveSnapshotMsg) Equals added in v1.7.0 

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

func (*RemoveSnapshotMsg) ToJSON added in v1.7.0 

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

type RemoveUserMsg added in v1.7.0 

type RemoveUserMsg struct {
	ColonyName string `json:"colonyname"`
	Name       string `json:"name"`
	MsgType    string `json:"msgtype"`
}

func CreateRemoveUserMsg added in v1.7.0 

func CreateRemoveUserMsg(colonyName string, name string) *RemoveUserMsg

func CreateRemoveUserMsgFromJSON added in v1.7.0 

func CreateRemoveUserMsgFromJSON(jsonString string) (*RemoveUserMsg, error)

func (*RemoveUserMsg) Equals added in v1.7.0 

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

func (*RemoveUserMsg) ToJSON added in v1.7.0 

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

func (*RemoveUserMsg) ToJSONIndent added in v1.7.0 

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

type ReportAllocationsMsg added in v1.7.8 

type ReportAllocationsMsg struct {
	ColonyName   string           `json:"colonyname"`
	ExecutorName string           `json:"executorname"`
	Allocations  core.Allocations `json:"allocations"`
	MsgType      string           `json:"msgtype"`
}

func CreateReportAllocationsMsg added in v1.7.8 

func CreateReportAllocationsMsg(colonyName string, executorName string, allocations core.Allocations) *ReportAllocationsMsg

func CreateReportAllocationsMsgFromJSON added in v1.7.8 

func CreateReportAllocationsMsgFromJSON(jsonString string) (*ReportAllocationsMsg, error)

func (*ReportAllocationsMsg) Equals added in v1.7.8 

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

func (*ReportAllocationsMsg) ToJSON added in v1.7.8 

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

func (*ReportAllocationsMsg) ToJSONIndent added in v1.7.8 

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

type ResolveGeneratorMsg 

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

func CreateResolveGeneratorMsg 

func CreateResolveGeneratorMsg(colonyName string, 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 SearchLogsMsg added in v1.7.7 

type SearchLogsMsg struct {
	ColonyName string `json:"colonyname"`
	Text       string `json:"text"`
	Days       int    `json:"days"`
	Count      int    `json:"count"`
	MsgType    string `json:"msgtype"`
}

func CreateSearchLogsMsg added in v1.7.7 

func CreateSearchLogsMsg(colonyName string, text string, days int, count int) *SearchLogsMsg

func CreateSearchLogsMsgFromJSON added in v1.7.7 

func CreateSearchLogsMsgFromJSON(jsonString string) (*SearchLogsMsg, error)

func (*SearchLogsMsg) Equals added in v1.7.7 

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

func (*SearchLogsMsg) ToJSON added in v1.7.7 

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

func (*SearchLogsMsg) ToJSONIndent added in v1.7.7 

func (msg *SearchLogsMsg) 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 {
	ColonyName   string `json:"colonyname"`
	ProcessID    string `json:"processid"`
	ExecutorType string `json:"executortype"`
	State        int    `json:"state"`
	Timeout      int    `json:"timeout"`
	MsgType      string `json:"msgtype"`
}

func CreateSubscribeProcessMsg 

func CreateSubscribeProcessMsg(colonyName string, 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 {
	ColonyName   string `json:"colonyname"`
	ExecutorType string `json:"executortype"`
	State        int    `json:"state"`
	Timeout      int    `json:"timeout"`
	MsgType      string `json:"msgtype"`
}

func CreateSubscribeProcessesMsg 

func CreateSubscribeProcessesMsg(colonyName string, 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.