The highest tagged major version is v2.

ipcs

package

v0.1.0 Latest Latest Go to latest Published: Apr 19, 2020 License: BSD-3-Clause Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func NewService(log logging.Logger, chainManager chains.Manager, events *triggers.EventDispatcher, httpServer *api.Server) *common.HTTPHandler

NewService returns a new IPCs API service

type ChainIPC struct {
	// contains filtered or unexported fields
}

ChainIPC a struct which holds IPC socket information

func (cipc *ChainIPC) Accept(chainID, containerID ids.ID, container []byte) error

Accept delivers a message to the ChainIPC

func (cipc *ChainIPC) Stop() error

Stop halts the ChainIPC event loop

type IPCs struct {
	// contains filtered or unexported fields
}

IPCs maintains the IPCs

func (ipc *IPCs) PublishBlockchain(r *http.Request, args *PublishBlockchainArgs, reply *PublishBlockchainReply) error

PublishBlockchain publishes the finalized accepted transactions from the blockchainID over the IPC

func (ipc *IPCs) UnpublishBlockchain(r *http.Request, args *UnpublishBlockchainArgs, reply *UnpublishBlockchainReply) error

UnpublishBlockchain closes publishing of a blockchainID

type PublishBlockchainArgs struct {
	BlockchainID string `json:"blockchainID"`
}

PublishBlockchainArgs are the arguments for calling PublishBlockchain

type PublishBlockchainReply struct {
	URL string `json:"url"`
}

PublishBlockchainReply are the results from calling PublishBlockchain

type UnpublishBlockchainArgs struct {
	BlockchainID string `json:"blockchainID"`
}

UnpublishBlockchainArgs are the arguments for calling UnpublishBlockchain

type UnpublishBlockchainReply struct {
	Success bool `json:"success"`
}

UnpublishBlockchainReply are the results from calling UnpublishBlockchain