socket

Documentation

Index

• Variables
• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) ClaimFee(chain string) (*ResClaimFee, error)
  • func (c *Client) Close() error
  • func (c *Client) GetBlock(chain string) ([]*ResGetBlock, error)
  • func (c *Client) GetFee(chain string, network string, isReponse bool) (*ResGetFee, error)
  • func (c *Client) GetMessageList(chain string, pagination *store.Pagination) (*ResMessageList, error)
  • func (c *Client) MessageRemove(chain string, sn *big.Int) (*ResMessageRemove, error)
  • func (c *Client) PruneDB() (*ResPruneDB, error)
  • func (c *Client) RelayMessage(chain string, height uint64, sn *big.Int) (*ResRelayMessage, error)
  • func (c *Client) RevertMessage(chain string, sn uint64) (*ResRevertMessage, error)
  • func (c *Client) SetFee(chain, network string, msgFee, resFee *big.Int) (*ResSetFee, error)
• type ErrResponse
• type Event
• type Message
• type ReqClaimFee
• type ReqGetBlock
• type ReqGetFee
• type ReqMessageList
• type ReqMessageRemove
• type ReqPruneDB
• type ReqRelayMessage
• type ReqRevertMessage
• type ReqSetFee
• type ResClaimFee
• type ResGetBlock
• type ResGetFee
• type ResMessageList
• type ResMessageRemove
• type ResPruneDB
• type ResRelayMessage
• type ResRevertMessage
• type ResSetFee
• type Server
  • func NewSocket(rly *relayer.Relayer) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) IsClosed() bool
  • func (s *Server) Listen()

Variables

var (
	ErrUnknownEvent    = fmt.Errorf("unknown event")
	ErrSocketClosed    = fmt.Errorf("socket closed")
	ErrInvalidResponse = func(err error) error {
		return fmt.Errorf("invalid response: %v", err)
	}
	ErrUnknown = fmt.Errorf("unknown error")
)

var (
	SocketPath = path.Join(os.TempDir(), "relayer.sock")
)

Types

type Client

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

func NewClient

func NewClient() (*Client, error)

func (*Client) ClaimFee

func (c *Client) ClaimFee(chain string) (*ResClaimFee, error)

ClaimFee sends ClaimFee event to socket

func (*Client) Close

func (c *Client) Close() error

func (*Client) GetBlock

func (c *Client) GetBlock(chain string) ([]*ResGetBlock, error)

GetBlock sends GetBlock event to socket

func (*Client) GetFee

func (c *Client) GetFee(chain string, network string, isReponse bool) (*ResGetFee, error)

GetFee sends GetFee event to socket

func (*Client) GetMessageList

func (c *Client) GetMessageList(chain string, pagination *store.Pagination) (*ResMessageList, error)

GetMessageList sends GetMessageList event to socket

func (*Client) MessageRemove

func (c *Client) MessageRemove(chain string, sn *big.Int) (*ResMessageRemove, error)

MessageRemove sends MessageRemove event to socket

func (*Client) PruneDB

func (c *Client) PruneDB() (*ResPruneDB, error)

PruneDB sends PruneDB event to socket

func (*Client) RelayMessage

func (c *Client) RelayMessage(chain string, height uint64, sn *big.Int) (*ResRelayMessage, error)

RelayMessage sends RelayMessage event to socket

func (*Client) RevertMessage

func (c *Client) RevertMessage(chain string, sn uint64) (*ResRevertMessage, error)

RevertMessage sends RevertMessage event to socket

func (*Client) SetFee

func (c *Client) SetFee(chain, network string, msgFee, resFee *big.Int) (*ResSetFee, error)

SetFee sends SetFee event to socket

type ErrResponse

type ErrResponse struct {
	Error string
}

type Event

type Event string

const (
	EventGetBlock       Event = "GetBlock"
	EventGetMessageList Event = "GetMessageList"
	EventRelayMessage   Event = "RelayMessage"
	EventMessageRemove  Event = "MessageRemove"
	EventPruneDB        Event = "PruneDB"
	EventRevertMessage  Event = "RevertMessage"
	EventError          Event = "Error"
	EventGetFee         Event = "GetFee"
	EventSetFee         Event = "SetFee"
	EventClaimFee       Event = "ClaimFee"
)

type Message

type Message struct {
	Event Event
	Data  []byte
}

type ReqClaimFee

type ReqClaimFee struct {
	Chain string
}

ReqClaimFee sends ClaimFee event to socket

type ReqGetBlock

type ReqGetBlock struct {
	Chain string
	All   bool
}

type ReqGetFee

type ReqGetFee struct {
	Chain    string
	Network  string
	Response bool
}

type ReqMessageList

type ReqMessageList struct {
	Chain      string
	Pagination *store.Pagination
}

type ReqMessageRemove

type ReqMessageRemove struct {
	Chain string
	Sn    *big.Int
}

type ReqPruneDB

type ReqPruneDB struct {
	Chain string
}

type ReqRelayMessage

type ReqRelayMessage struct {
	Chain  string
	Sn     *big.Int
	Height uint64
}

type ReqRevertMessage

type ReqRevertMessage struct {
	Chain string
	Sn    uint64
}

type ReqSetFee

type ReqSetFee struct {
	Chain   string
	Network string
	MsgFee  *big.Int
	ResFee  *big.Int
}

ReqSetFee sends SetFee event to socket

type ResClaimFee

type ResClaimFee struct {
	Status string
}

ResClaimFee sends ClaimFee event to socket

type ResGetBlock

type ResGetBlock struct {
	Chain  string
	Height uint64
}

type ResGetFee

type ResGetFee struct {
	Chain    string
	Fee      uint64
	Response bool
}

type ResMessageList

type ResMessageList struct {
	Messages []*types.RouteMessage
	Total    int
}

type ResMessageRemove

type ResMessageRemove struct {
	Sn     *big.Int
	Chain  string
	Dst    string
	Height uint64
	Event  string
}

type ResPruneDB

type ResPruneDB struct {
	Status string
}

type ResRelayMessage

type ResRelayMessage struct {
	*types.RouteMessage
}

type ResRevertMessage

type ResRevertMessage struct {
	Sn uint64
}

type ResSetFee

type ResSetFee struct {
	Status string
}

ResSetFee sends SetFee event to socket

type Server

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

func NewSocket

func NewSocket(rly *relayer.Relayer) (*Server, error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) IsClosed

func (s *Server) IsClosed() bool

func (*Server) Listen

func (s *Server) Listen()

Listen to socket