request

Documentation

Index

• type DisbandCluster
  • func (d DisbandCluster) MarshalJSON() ([]byte, error)
  • func (DisbandCluster) Type() string
• type Execute
  • func (e Execute) MarshalJSON() ([]byte, error)
  • func (e Execute) Response(c codes.Code) *response.Execute
  • func (Execute) Type() string
  • func (e Execute) Valid() error
• type FormCluster
  • func (f FormCluster) MarshalJSON() ([]byte, error)
  • func (f FormCluster) Response(c codes.Code) *response.FormCluster
  • func (FormCluster) Type() string
• type InstallFunction
  • func (f InstallFunction) MarshalJSON() ([]byte, error)
  • func (f InstallFunction) Response(c codes.Code) *response.InstallFunction
  • func (InstallFunction) Type() string
• type RollCall
  • func (r RollCall) MarshalJSON() ([]byte, error)
  • func (r RollCall) Response(c codes.Code) *response.RollCall
  • func (RollCall) Type() string

Types

type DisbandCluster

type DisbandCluster struct {
	blockless.BaseMessage
	RequestID string `json:"request_id,omitempty"`
}

DisbandCluster describes the `MessageDisbandCluster` request payload. It is sent after head node receives the leaders execution response.

func (DisbandCluster) MarshalJSON

func (d DisbandCluster) MarshalJSON() ([]byte, error)

func (DisbandCluster) Type

func (DisbandCluster) Type() string

type Execute

type Execute struct {
	blockless.BaseMessage

	execute.Request // execute request is embedded.

	Topic     string    `json:"topic,omitempty"`
	RequestID string    `json:"request_id,omitempty"` // RequestID may be set initially, if the execution request is relayed via roll-call.
	Timestamp time.Time `json:"timestamp,omitempty"`  // Execution request timestamp is a factor for PBFT.
}

Execute describes the `MessageExecute` request payload.

func (Execute) MarshalJSON

func (e Execute) MarshalJSON() ([]byte, error)

func (Execute) Response

func (e Execute) Response(c codes.Code) *response.Execute

func (Execute) Type

func (Execute) Type() string

func (Execute) Valid

func (e Execute) Valid() error

type FormCluster

type FormCluster struct {
	blockless.BaseMessage
	RequestID      string          `json:"request_id,omitempty"`
	Peers          []peer.ID       `json:"peers,omitempty"`
	Consensus      consensus.Type  `json:"consensus,omitempty"`
	ConnectionInfo []peer.AddrInfo `json:"connection_info,omitempty"`
}

FormCluster describes the `MessageFormCluster` request payload. It is sent on clustered execution of a request.

func (FormCluster) MarshalJSON

func (f FormCluster) MarshalJSON() ([]byte, error)

func (FormCluster) Response

func (f FormCluster) Response(c codes.Code) *response.FormCluster

func (FormCluster) Type

func (FormCluster) Type() string

type InstallFunction

type InstallFunction struct {
	blockless.BaseMessage
	ManifestURL string `json:"manifest_url,omitempty"`
	CID         string `json:"cid,omitempty"`
}

InstallFunction describes the `MessageInstallFunction` request payload.

func (InstallFunction) MarshalJSON

func (f InstallFunction) MarshalJSON() ([]byte, error)

func (InstallFunction) Response

func (f InstallFunction) Response(c codes.Code) *response.InstallFunction

func (InstallFunction) Type

func (InstallFunction) Type() string

type RollCall

type RollCall struct {
	blockless.BaseMessage
	Origin     peer.ID             `json:"origin,omitempty"` // Origin is the peer that initiated the roll call.
	FunctionID string              `json:"function_id,omitempty"`
	RequestID  string              `json:"request_id,omitempty"`
	Consensus  consensus.Type      `json:"consensus"`
	Attributes *execute.Attributes `json:"attributes,omitempty"`
}

RollCall describes the `MessageRollCall` message payload.

func (RollCall) MarshalJSON

func (r RollCall) MarshalJSON() ([]byte, error)

func (RollCall) Response

func (r RollCall) Response(c codes.Code) *response.RollCall

func (RollCall) Type

func (RollCall) Type() string