rpc

package
v1.9.12 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const AddAttributePayloadType = "addattributemsg"
View Source 
const AddBlueprintDefinitionPayloadType = "addblueprintdefinitionmsg"
View Source 
const AddBlueprintPayloadType = "addblueprintmsg"
View Source 
const AddChildPayloadType = "addchildmsg"
View Source 
const AddColonyPayloadType = "addcolonymsg"
View Source 
const AddCronPayloadType = "addcronmsg"
View Source 
const AddExecutorLogPayloadType = "addexecutorlogmsg"
View Source 
const AddExecutorPayloadType = "addexecutormsg"
View Source 
const AddFilePayloadType = "addfilemsg"
View Source 
const AddFunctionPayloadType = "addfunctionmsg"
View Source 
const AddGeneratorPayloadType = "addgeneratormsg"
View Source 
const AddLocationPayloadType = "addlocationmsg"
View Source 
const AddLogPayloadType = "addlogmsg"
View Source 
const AddUserPayloadType = "addusermsg"
View Source 
const ApproveExecutorPayloadType = "approveexecutormsg"
View Source 
const AssignProcessPayloadType = "assignprocessmsg"
View Source 
const CancelProcessGraphPayloadType = "cancelprocessgraphmsg"
View Source 
const CancelProcessPayloadType = "cancelprocessmsg"
View Source 
const ChangeColonyIDPayloadType = "changecolonyidmsg"
View Source 
const ChangeExecutorIDPayloadType = "changeexecutoridmsg"
View Source 
const ChangeServerIDPayloadType = "changeserveridmsg"
View Source 
const ChangeUserIDPayloadType = "changeuseridmsg"
View Source 
const ChannelAppendPayloadType = "channelappendmsg"
View Source 
const ChannelReadPayloadType = "channelreadmsg"
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 GetBlueprintDefinitionPayloadType = "getblueprintdefinitionmsg"
View Source 
const GetBlueprintDefinitionsPayloadType = "getblueprintdefinitionsmsg"
View Source 
const GetBlueprintHistoryPayloadType = "getblueprinthistorymsg"
View Source 
const GetBlueprintPayloadType = "getblueprintmsg"
View Source 
const GetBlueprintsPayloadType = "getblueprintsmsg"
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 GetExecutorByIDPayloadType = "getexecutorbyidmsg"
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 GetLocationPayloadType = "getlocationmsg"
View Source 
const GetLocationsPayloadType = "getlocationsmsg"
View Source 
const GetLogsPayloadType = "getlogsmsg"
View Source 
const GetNodePayloadType = "getnodemsg"
View Source 
const GetNodesByLocationPayloadType = "getnodesbylocationmsg"
View Source 
const GetNodesPayloadType = "getnodesmsg"
View Source 
const GetPauseStatusPayloadType = "getpausestatusmsg"
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 GetServerInfoPayloadType = "getserverinfomsg"
View Source 
const GetSnapshotPayloadType = "getsnapshotmsg"
View Source 
const GetSnapshotsPayloadType = "getsnapshotsmsg"
View Source 
const GetStatisiticsPayloadType = "getstatisticsmsg"
View Source 
const GetUserByIDPayloadType = "getuserbyidmsg"
View Source 
const GetUserPayloadType = "getusermsg"
View Source 
const GetUsersPayloadType = "getusersmsg"
View Source 
const PackGeneratorPayloadType = "packgeneratormsg"
View Source 
const PauseAssignmentsPayloadType = "pauseassignmentsmsg"
View Source 
const PauseStatusReplyPayloadType = "pausestatusreplymsg"
View Source 
const ReconcileBlueprintPayloadType = "reconcileblueprintmsg"
View Source 
const RejectExecutorPayloadType = "rejectexecutormsg"
View Source 
const RemoveAllProcessGraphsPayloadType = "removeallprocessgraphsmsg"
View Source 
const RemoveAllProcessesPayloadType = "removeallprocessesmsg"
View Source 
const RemoveAllSnapshotsPayloadType = "removeallsnapshotmsg"
View Source 
const RemoveBlueprintDefinitionPayloadType = "removeblueprintdefinitionmsg"
View Source 
const RemoveBlueprintPayloadType = "removeblueprintmsg"
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 RemoveLocationPayloadType = "removelocationmsg"
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 ResumeAssignmentsPayloadType = "resumeassignmentsmsg"
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 SubscribeChannelPayloadType = "subscribechannelmsg"
View Source 
const SubscribeProcessPayloadType = "subscribeprocessmsg"
View Source 
const SubscribeProcessesPayloadType = "subscribeprocessesmsg"
View Source 
const UpdateBlueprintPayloadType = "updateblueprintmsg"
View Source 
const UpdateBlueprintStatusPayloadType = "updateblueprintstatusmsg"
View Source 
const UpdateExecutorPayloadType = "updateexecutormsg"
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 AddBlueprintDefinitionMsg added in v1.9.3 

type AddBlueprintDefinitionMsg struct {
	BlueprintDefinition *core.BlueprintDefinition `json:"blueprintdefinition"`
	MsgType             string                    `json:"msgtype"`
}

func CreateAddBlueprintDefinitionMsg added in v1.9.3 

func CreateAddBlueprintDefinitionMsg(sd *core.BlueprintDefinition) *AddBlueprintDefinitionMsg

func CreateAddBlueprintDefinitionMsgFromJSON added in v1.9.3 

func CreateAddBlueprintDefinitionMsgFromJSON(jsonString string) (*AddBlueprintDefinitionMsg, error)

func (*AddBlueprintDefinitionMsg) Equals added in v1.9.3 

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

func (*AddBlueprintDefinitionMsg) ToJSON added in v1.9.3 

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

func (*AddBlueprintDefinitionMsg) ToJSONIndent added in v1.9.3 

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

type AddBlueprintMsg added in v1.9.3 

type AddBlueprintMsg struct {
	Blueprint *core.Blueprint `json:"blueprint"`
	MsgType   string          `json:"msgtype"`
}

func CreateAddBlueprintMsg added in v1.9.3 

func CreateAddBlueprintMsg(blueprint *core.Blueprint) *AddBlueprintMsg

func CreateAddBlueprintMsgFromJSON added in v1.9.3 

func CreateAddBlueprintMsgFromJSON(jsonString string) (*AddBlueprintMsg, error)

func (*AddBlueprintMsg) Equals added in v1.9.3 

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

func (*AddBlueprintMsg) ToJSON added in v1.9.3 

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

func (*AddBlueprintMsg) ToJSONIndent added in v1.9.3 

func (msg *AddBlueprintMsg) 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 AddExecutorLogMsg added in v1.9.6 

type AddExecutorLogMsg struct {
	ColonyName   string `json:"colonyname"`
	ExecutorName string `json:"executorname"`
	Message      string `json:"message"`
	MsgType      string `json:"msgtype"`
}

func CreateAddExecutorLogMsg added in v1.9.6 

func CreateAddExecutorLogMsg(colonyName, executorName, message string) *AddExecutorLogMsg

func CreateAddExecutorLogMsgFromJSON added in v1.9.6 

func CreateAddExecutorLogMsgFromJSON(jsonString string) (*AddExecutorLogMsg, error)

func (*AddExecutorLogMsg) Equals added in v1.9.6 

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

func (*AddExecutorLogMsg) ToJSON added in v1.9.6 

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

func (*AddExecutorLogMsg) ToJSONIndent added in v1.9.6 

func (msg *AddExecutorLogMsg) 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 AddLocationMsg added in v1.9.6 

type AddLocationMsg struct {
	Location *core.Location `json:"location"`
	MsgType  string         `json:"msgtype"`
}

func CreateAddLocationMsg added in v1.9.6 

func CreateAddLocationMsg(location *core.Location) *AddLocationMsg

func CreateAddLocationMsgFromJSON added in v1.9.6 

func CreateAddLocationMsgFromJSON(jsonString string) (*AddLocationMsg, error)

func (*AddLocationMsg) Equals added in v1.9.6 

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

func (*AddLocationMsg) ToJSON added in v1.9.6 

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

func (*AddLocationMsg) ToJSONIndent added in v1.9.6 

func (msg *AddLocationMsg) 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 CancelProcessGraphMsg added in v1.9.12 

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

func CreateCancelProcessGraphMsg added in v1.9.12 

func CreateCancelProcessGraphMsg(processGraphID string) *CancelProcessGraphMsg

func CreateCancelProcessGraphMsgFromJSON added in v1.9.12 

func CreateCancelProcessGraphMsgFromJSON(jsonString string) (*CancelProcessGraphMsg, error)

func (*CancelProcessGraphMsg) Equals added in v1.9.12 

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

func (*CancelProcessGraphMsg) ToJSON added in v1.9.12 

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

func (*CancelProcessGraphMsg) ToJSONIndent added in v1.9.12 

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

type CancelProcessMsg added in v1.9.12 

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

func CreateCancelProcessMsg added in v1.9.12 

func CreateCancelProcessMsg(processID string) *CancelProcessMsg

func CreateCancelProcessMsgFromJSON added in v1.9.12 

func CreateCancelProcessMsgFromJSON(jsonString string) (*CancelProcessMsg, error)

func (*CancelProcessMsg) Equals added in v1.9.12 

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

func (*CancelProcessMsg) ToJSON added in v1.9.12 

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

func (*CancelProcessMsg) ToJSONIndent added in v1.9.12 

func (msg *CancelProcessMsg) 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 ChannelAppendMsg added in v1.9.6 

type ChannelAppendMsg struct {
	ProcessID   string `json:"processid"`
	Name        string `json:"name"`
	Sequence    int64  `json:"sequence"`            // Client-assigned sequence number
	InReplyTo   int64  `json:"inreplyto,omitempty"` // References sequence from other sender
	Payload     []byte `json:"payload"`
	MsgType     string `json:"msgtype"`
	PayloadType string `json:"payloadtype,omitempty"` // Message type: "", "end", "error"
}

func CreateChannelAppendMsg added in v1.9.6 

func CreateChannelAppendMsg(processID string, name string, sequence int64, inReplyTo int64, payload []byte) *ChannelAppendMsg

func CreateChannelAppendMsgFromJSON added in v1.9.6 

func CreateChannelAppendMsgFromJSON(jsonString string) (*ChannelAppendMsg, error)

func CreateChannelAppendMsgWithType added in v1.9.6 

func CreateChannelAppendMsgWithType(processID string, name string, sequence int64, inReplyTo int64, payload []byte, payloadType string) *ChannelAppendMsg

func (*ChannelAppendMsg) Equals added in v1.9.6 

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

func (*ChannelAppendMsg) ToJSON added in v1.9.6 

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

type ChannelReadMsg added in v1.9.6 

type ChannelReadMsg struct {
	ProcessID string `json:"processid"`
	Name      string `json:"name"`
	AfterSeq  int64  `json:"afterseq"`
	Limit     int    `json:"limit"`
	MsgType   string `json:"msgtype"`
}

func CreateChannelReadMsg added in v1.9.6 

func CreateChannelReadMsg(processID string, name string, afterSeq int64, limit int) *ChannelReadMsg

func CreateChannelReadMsgFromJSON added in v1.9.6 

func CreateChannelReadMsgFromJSON(jsonString string) (*ChannelReadMsg, error)

func (*ChannelReadMsg) Equals added in v1.9.6 

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

func (*ChannelReadMsg) ToJSON added in v1.9.6 

func (msg *ChannelReadMsg) ToJSON() (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 GetBlueprintDefinitionMsg added in v1.9.3 

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

func CreateGetBlueprintDefinitionMsg added in v1.9.3 

func CreateGetBlueprintDefinitionMsg(colonyName, name string) *GetBlueprintDefinitionMsg

func CreateGetBlueprintDefinitionMsgFromJSON added in v1.9.3 

func CreateGetBlueprintDefinitionMsgFromJSON(jsonString string) (*GetBlueprintDefinitionMsg, error)

func (*GetBlueprintDefinitionMsg) Equals added in v1.9.3 

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

func (*GetBlueprintDefinitionMsg) ToJSON added in v1.9.3 

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

func (*GetBlueprintDefinitionMsg) ToJSONIndent added in v1.9.3 

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

type GetBlueprintDefinitionsMsg added in v1.9.3 

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

func CreateGetBlueprintDefinitionsMsg added in v1.9.3 

func CreateGetBlueprintDefinitionsMsg(colonyName string) *GetBlueprintDefinitionsMsg

func CreateGetBlueprintDefinitionsMsgFromJSON added in v1.9.3 

func CreateGetBlueprintDefinitionsMsgFromJSON(jsonString string) (*GetBlueprintDefinitionsMsg, error)

func (*GetBlueprintDefinitionsMsg) Equals added in v1.9.3 

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

func (*GetBlueprintDefinitionsMsg) ToJSON added in v1.9.3 

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

type GetBlueprintDefinitionsReplyMsg added in v1.9.3 

type GetBlueprintDefinitionsReplyMsg struct {
	BlueprintDefinitions []*core.BlueprintDefinition `json:"blueprintdefinitions"`
	MsgType              string                      `json:"msgtype"`
}

func CreateGetBlueprintDefinitionsReplyMsg added in v1.9.3 

func CreateGetBlueprintDefinitionsReplyMsg(sds []*core.BlueprintDefinition) *GetBlueprintDefinitionsReplyMsg

func CreateGetBlueprintDefinitionsReplyMsgFromJSON added in v1.9.3 

func CreateGetBlueprintDefinitionsReplyMsgFromJSON(jsonString string) (*GetBlueprintDefinitionsReplyMsg, error)

func (*GetBlueprintDefinitionsReplyMsg) Equals added in v1.9.3 

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

func (*GetBlueprintDefinitionsReplyMsg) ToJSON added in v1.9.3 

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

type GetBlueprintHistoryMsg added in v1.9.3 

type GetBlueprintHistoryMsg struct {
	BlueprintID string `json:"blueprintid"`
	Limit       int    `json:"limit,omitempty"`
	MsgType     string `json:"msgtype"`
}

func CreateGetBlueprintHistoryMsg added in v1.9.3 

func CreateGetBlueprintHistoryMsg(blueprintID string, limit int) *GetBlueprintHistoryMsg

func CreateGetBlueprintHistoryMsgFromJSON added in v1.9.3 

func CreateGetBlueprintHistoryMsgFromJSON(jsonString string) (*GetBlueprintHistoryMsg, error)

func (*GetBlueprintHistoryMsg) ToJSON added in v1.9.3 

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

type GetBlueprintMsg added in v1.9.3 

type GetBlueprintMsg struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
	MsgType   string `json:"msgtype"`
}

func CreateGetBlueprintMsg added in v1.9.3 

func CreateGetBlueprintMsg(namespace, name string) *GetBlueprintMsg

func CreateGetBlueprintMsgFromJSON added in v1.9.3 

func CreateGetBlueprintMsgFromJSON(jsonString string) (*GetBlueprintMsg, error)

func (*GetBlueprintMsg) Equals added in v1.9.3 

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

func (*GetBlueprintMsg) ToJSON added in v1.9.3 

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

func (*GetBlueprintMsg) ToJSONIndent added in v1.9.3 

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

type GetBlueprintsMsg added in v1.9.3 

type GetBlueprintsMsg struct {
	Namespace    string `json:"namespace"`
	Kind         string `json:"kind"`
	LocationName string `json:"locationname"`
	MsgType      string `json:"msgtype"`
}

func CreateGetBlueprintsMsg added in v1.9.3 

func CreateGetBlueprintsMsg(namespace, kind, locationName string) *GetBlueprintsMsg

func CreateGetBlueprintsMsgFromJSON added in v1.9.3 

func CreateGetBlueprintsMsgFromJSON(jsonString string) (*GetBlueprintsMsg, error)

func (*GetBlueprintsMsg) Equals added in v1.9.3 

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

func (*GetBlueprintsMsg) ToJSON added in v1.9.3 

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

func (*GetBlueprintsMsg) ToJSONIndent added in v1.9.3 

func (msg *GetBlueprintsMsg) 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 GetExecutorByIDMsg added in v1.9.3 

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

func CreateGetExecutorByIDMsg added in v1.9.3 

func CreateGetExecutorByIDMsg(colonyName string, executorID string) *GetExecutorByIDMsg

func CreateGetExecutorByIDMsgFromJSON added in v1.9.3 

func CreateGetExecutorByIDMsgFromJSON(jsonString string) (*GetExecutorByIDMsg, error)

func (*GetExecutorByIDMsg) Equals added in v1.9.3 

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

func (*GetExecutorByIDMsg) ToJSON added in v1.9.3 

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

func (*GetExecutorByIDMsg) ToJSONIndent added in v1.9.3 

func (msg *GetExecutorByIDMsg) 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 GetLocationMsg added in v1.9.6 

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

func CreateGetLocationMsg added in v1.9.6 

func CreateGetLocationMsg(colonyName string, name string) *GetLocationMsg

func CreateGetLocationMsgFromJSON added in v1.9.6 

func CreateGetLocationMsgFromJSON(jsonString string) (*GetLocationMsg, error)

func (*GetLocationMsg) Equals added in v1.9.6 

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

func (*GetLocationMsg) ToJSON added in v1.9.6 

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

func (*GetLocationMsg) ToJSONIndent added in v1.9.6 

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

type GetLocationsMsg added in v1.9.6 

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

func CreateGetLocationsMsg added in v1.9.6 

func CreateGetLocationsMsg(colonyName string) *GetLocationsMsg

func CreateGetLocationsMsgFromJSON added in v1.9.6 

func CreateGetLocationsMsgFromJSON(jsonString string) (*GetLocationsMsg, error)

func (*GetLocationsMsg) Equals added in v1.9.6 

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

func (*GetLocationsMsg) ToJSON added in v1.9.6 

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

func (*GetLocationsMsg) ToJSONIndent added in v1.9.6 

func (msg *GetLocationsMsg) 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"`
	Latest       bool   `json:"latest"` // If true, return latest logs (descending order)
	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 GetNodeMsg added in v1.9.3 

type GetNodeMsg struct {
	ColonyName string `json:"colonyname"`
	NodeName   string `json:"nodename"`
	MsgType    string `json:"msgtype"`
}

func CreateGetNodeMsg added in v1.9.3 

func CreateGetNodeMsg(colonyName string, nodeName string) *GetNodeMsg

func CreateGetNodeMsgFromJSON added in v1.9.3 

func CreateGetNodeMsgFromJSON(jsonString string) (*GetNodeMsg, error)

func (*GetNodeMsg) Equals added in v1.9.3 

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

func (*GetNodeMsg) ToJSON added in v1.9.3 

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

func (*GetNodeMsg) ToJSONIndent added in v1.9.3 

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

type GetNodesByLocationMsg added in v1.9.3 

type GetNodesByLocationMsg struct {
	ColonyName string `json:"colonyname"`
	Location   string `json:"location"`
	MsgType    string `json:"msgtype"`
}

func CreateGetNodesByLocationMsg added in v1.9.3 

func CreateGetNodesByLocationMsg(colonyName string, location string) *GetNodesByLocationMsg

func CreateGetNodesByLocationMsgFromJSON added in v1.9.3 

func CreateGetNodesByLocationMsgFromJSON(jsonString string) (*GetNodesByLocationMsg, error)

func (*GetNodesByLocationMsg) Equals added in v1.9.3 

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

func (*GetNodesByLocationMsg) ToJSON added in v1.9.3 

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

func (*GetNodesByLocationMsg) ToJSONIndent added in v1.9.3 

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

type GetNodesMsg added in v1.9.3 

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

func CreateGetNodesMsg added in v1.9.3 

func CreateGetNodesMsg(colonyName string) *GetNodesMsg

func CreateGetNodesMsgFromJSON added in v1.9.3 

func CreateGetNodesMsgFromJSON(jsonString string) (*GetNodesMsg, error)

func (*GetNodesMsg) Equals added in v1.9.3 

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

func (*GetNodesMsg) ToJSON added in v1.9.3 

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

func (*GetNodesMsg) ToJSONIndent added in v1.9.3 

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

type GetPauseStatusMsg added in v1.8.19 

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

func CreateGetPauseStatusMsg added in v1.8.19 

func CreateGetPauseStatusMsg(colonyName string) *GetPauseStatusMsg

func CreateGetPauseStatusMsgFromJSON added in v1.8.19 

func CreateGetPauseStatusMsgFromJSON(jsonString string) (*GetPauseStatusMsg, error)

func (*GetPauseStatusMsg) Equals added in v1.8.19 

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

func (*GetPauseStatusMsg) ToJSON added in v1.8.19 

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

func (*GetPauseStatusMsg) ToJSONIndent added in v1.8.19 

func (msg *GetPauseStatusMsg) 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 GetServerInfoMsg added in v1.9.0 

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

func CreateGetServerInfoMsg added in v1.9.0 

func CreateGetServerInfoMsg() *GetServerInfoMsg

func CreateGetServerInfoMsgFromJSON added in v1.9.0 

func CreateGetServerInfoMsgFromJSON(jsonString string) (*GetServerInfoMsg, error)

func (*GetServerInfoMsg) ToJSON added in v1.9.0 

func (msg *GetServerInfoMsg) ToJSON() (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 GetUserByIDMsg added in v1.9.3 

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

func CreateGetUserByIDMsg added in v1.9.3 

func CreateGetUserByIDMsg(colonyName string, userID string) *GetUserByIDMsg

func CreateGetUserByIDMsgFromJSON added in v1.9.3 

func CreateGetUserByIDMsgFromJSON(jsonString string) (*GetUserByIDMsg, error)

func (*GetUserByIDMsg) Equals added in v1.9.3 

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

func (*GetUserByIDMsg) ToJSON added in v1.9.3 

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

func (*GetUserByIDMsg) ToJSONIndent added in v1.9.3 

func (msg *GetUserByIDMsg) 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 PauseAssignmentsMsg added in v1.8.19 

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

func CreatePauseAssignmentsMsg added in v1.8.19 

func CreatePauseAssignmentsMsg(colonyName string) *PauseAssignmentsMsg

func CreatePauseAssignmentsMsgFromJSON added in v1.8.19 

func CreatePauseAssignmentsMsgFromJSON(jsonString string) (*PauseAssignmentsMsg, error)

func (*PauseAssignmentsMsg) Equals added in v1.8.19 

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

func (*PauseAssignmentsMsg) ToJSON added in v1.8.19 

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

func (*PauseAssignmentsMsg) ToJSONIndent added in v1.8.19 

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

type PauseStatusReplyMsg added in v1.8.19 

type PauseStatusReplyMsg struct {
	MsgType    string `json:"msgtype"`
	ColonyName string `json:"colonyname"`
	IsPaused   bool   `json:"ispaused"`
}

func CreatePauseStatusReplyMsg added in v1.8.19 

func CreatePauseStatusReplyMsg(colonyName string, isPaused bool) *PauseStatusReplyMsg

func CreatePauseStatusReplyMsgFromJSON added in v1.8.19 

func CreatePauseStatusReplyMsgFromJSON(jsonString string) (*PauseStatusReplyMsg, error)

func (*PauseStatusReplyMsg) Equals added in v1.8.19 

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

func (*PauseStatusReplyMsg) ToJSON added in v1.8.19 

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

func (*PauseStatusReplyMsg) ToJSONIndent added in v1.8.19 

func (msg *PauseStatusReplyMsg) 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 ReconcileBlueprintMsg added in v1.9.6 

type ReconcileBlueprintMsg struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
	Force     bool   `json:"force"`
	MsgType   string `json:"msgtype"`
}

func CreateReconcileBlueprintMsg added in v1.9.6 

func CreateReconcileBlueprintMsg(namespace, name string, force bool) *ReconcileBlueprintMsg

func CreateReconcileBlueprintMsgFromJSON added in v1.9.6 

func CreateReconcileBlueprintMsgFromJSON(jsonString string) (*ReconcileBlueprintMsg, error)

func (*ReconcileBlueprintMsg) Equals added in v1.9.6 

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

func (*ReconcileBlueprintMsg) ToJSON added in v1.9.6 

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

func (*ReconcileBlueprintMsg) ToJSONIndent added in v1.9.6 

func (msg *ReconcileBlueprintMsg) 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 RemoveBlueprintDefinitionMsg added in v1.9.3 

type RemoveBlueprintDefinitionMsg struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
	MsgType   string `json:"msgtype"`
}

func CreateRemoveBlueprintDefinitionMsg added in v1.9.3 

func CreateRemoveBlueprintDefinitionMsg(namespace, name string) *RemoveBlueprintDefinitionMsg

func CreateRemoveBlueprintDefinitionMsgFromJSON added in v1.9.3 

func CreateRemoveBlueprintDefinitionMsgFromJSON(jsonString string) (*RemoveBlueprintDefinitionMsg, error)

func (*RemoveBlueprintDefinitionMsg) Equals added in v1.9.3 

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

func (*RemoveBlueprintDefinitionMsg) ToJSON added in v1.9.3 

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

func (*RemoveBlueprintDefinitionMsg) ToJSONIndent added in v1.9.3 

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

type RemoveBlueprintMsg added in v1.9.3 

type RemoveBlueprintMsg struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
	MsgType   string `json:"msgtype"`
}

func CreateRemoveBlueprintMsg added in v1.9.3 

func CreateRemoveBlueprintMsg(namespace, name string) *RemoveBlueprintMsg

func CreateRemoveBlueprintMsgFromJSON added in v1.9.3 

func CreateRemoveBlueprintMsgFromJSON(jsonString string) (*RemoveBlueprintMsg, error)

func (*RemoveBlueprintMsg) Equals added in v1.9.3 

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

func (*RemoveBlueprintMsg) ToJSON added in v1.9.3 

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

func (*RemoveBlueprintMsg) ToJSONIndent added in v1.9.3 

func (msg *RemoveBlueprintMsg) ToJSONIndent() (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 RemoveLocationMsg added in v1.9.6 

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

func CreateRemoveLocationMsg added in v1.9.6 

func CreateRemoveLocationMsg(colonyName string, name string) *RemoveLocationMsg

func CreateRemoveLocationMsgFromJSON added in v1.9.6 

func CreateRemoveLocationMsgFromJSON(jsonString string) (*RemoveLocationMsg, error)

func (*RemoveLocationMsg) Equals added in v1.9.6 

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

func (*RemoveLocationMsg) ToJSON added in v1.9.6 

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

func (*RemoveLocationMsg) ToJSONIndent added in v1.9.6 

func (msg *RemoveLocationMsg) 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 ResumeAssignmentsMsg added in v1.8.19 

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

func CreateResumeAssignmentsMsg added in v1.8.19 

func CreateResumeAssignmentsMsg(colonyName string) *ResumeAssignmentsMsg

func CreateResumeAssignmentsMsgFromJSON added in v1.8.19 

func CreateResumeAssignmentsMsgFromJSON(jsonString string) (*ResumeAssignmentsMsg, error)

func (*ResumeAssignmentsMsg) Equals added in v1.8.19 

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

func (*ResumeAssignmentsMsg) ToJSON added in v1.8.19 

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

func (*ResumeAssignmentsMsg) ToJSONIndent added in v1.8.19 

func (msg *ResumeAssignmentsMsg) 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 SubscribeChannelMsg added in v1.9.6 

type SubscribeChannelMsg struct {
	ProcessID string `json:"processid"`
	Name      string `json:"name"`
	AfterSeq  int64  `json:"afterseq"`
	Timeout   int    `json:"timeout"`
	MsgType   string `json:"msgtype"`
}

func CreateSubscribeChannelMsg added in v1.9.6 

func CreateSubscribeChannelMsg(processID string, name string, afterSeq int64, timeout int) *SubscribeChannelMsg

func CreateSubscribeChannelMsgFromJSON added in v1.9.6 

func CreateSubscribeChannelMsgFromJSON(jsonString string) (*SubscribeChannelMsg, error)

func (*SubscribeChannelMsg) Equals added in v1.9.6 

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

func (*SubscribeChannelMsg) ToJSON added in v1.9.6 

func (msg *SubscribeChannelMsg) ToJSON() (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 UpdateBlueprintMsg added in v1.9.3 

type UpdateBlueprintMsg struct {
	Blueprint       *core.Blueprint `json:"blueprint"`
	ForceGeneration bool            `json:"forcegeneration"` // If true, increment generation even if spec hasn't changed
	MsgType         string          `json:"msgtype"`
}

func CreateUpdateBlueprintMsg added in v1.9.3 

func CreateUpdateBlueprintMsg(blueprint *core.Blueprint) *UpdateBlueprintMsg

func CreateUpdateBlueprintMsgFromJSON added in v1.9.3 

func CreateUpdateBlueprintMsgFromJSON(jsonString string) (*UpdateBlueprintMsg, error)

func CreateUpdateBlueprintMsgWithForce added in v1.9.6 

func CreateUpdateBlueprintMsgWithForce(blueprint *core.Blueprint, forceGeneration bool) *UpdateBlueprintMsg

func (*UpdateBlueprintMsg) Equals added in v1.9.3 

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

func (*UpdateBlueprintMsg) ToJSON added in v1.9.3 

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

func (*UpdateBlueprintMsg) ToJSONIndent added in v1.9.3 

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

type UpdateBlueprintStatusMsg added in v1.9.6 

type UpdateBlueprintStatusMsg struct {
	ColonyName    string                 `json:"colonyname"`
	BlueprintName string                 `json:"blueprintname"`
	Status        map[string]interface{} `json:"status"`
	MsgType       string                 `json:"msgtype"`
}

func CreateUpdateBlueprintStatusMsg added in v1.9.6 

func CreateUpdateBlueprintStatusMsg(colonyName, blueprintName string, status map[string]interface{}) *UpdateBlueprintStatusMsg

func CreateUpdateBlueprintStatusMsgFromJSON added in v1.9.6 

func CreateUpdateBlueprintStatusMsgFromJSON(jsonString string) (*UpdateBlueprintStatusMsg, error)

func (*UpdateBlueprintStatusMsg) Equals added in v1.9.6 

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

func (*UpdateBlueprintStatusMsg) ToJSON added in v1.9.6 

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

func (*UpdateBlueprintStatusMsg) ToJSONIndent added in v1.9.6 

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

type UpdateExecutorMsg added in v1.9.6 

type UpdateExecutorMsg struct {
	ColonyName   string            `json:"colonyname"`
	ExecutorName string            `json:"executorname"`
	Capabilities core.Capabilities `json:"capabilities"`
	MsgType      string            `json:"msgtype"`
}

func CreateUpdateExecutorMsg added in v1.9.6 

func CreateUpdateExecutorMsg(colonyName string, executorName string, capabilities core.Capabilities) *UpdateExecutorMsg

func CreateUpdateExecutorMsgFromJSON added in v1.9.6 

func CreateUpdateExecutorMsgFromJSON(jsonString string) (*UpdateExecutorMsg, error)

func (*UpdateExecutorMsg) Equals added in v1.9.6 

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

func (*UpdateExecutorMsg) ToJSON added in v1.9.6 

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

func (*UpdateExecutorMsg) ToJSONIndent added in v1.9.6 

func (msg *UpdateExecutorMsg) 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.