ccq

Documentation

Index

• Constants
• Variables
• func FetchCurrentPhylaxSet(rpcUrl, coreAddr string) (*common.PhylaxSet, error)
• func NewHTTPServer(addr string, t *pubsub.Topic, permissions Permissions, ...) *http.Server
• func NewStatusServer(addr string, logger *zap.Logger, env common.Environment) *http.Server
• type AllowedCall
• type Config
• type EthCall
• type EthCallByTimestamp
• type EthCallWithFinality
• type P2PSub
• type PendingResponse
  • func NewPendingResponse(req *gossipv1.SignedQueryRequest) *PendingResponse
• type PendingResponses
  • func NewPendingResponses() *PendingResponses
  • func (p *PendingResponses) Add(r *PendingResponse) bool
  • func (p *PendingResponses) Get(signature string) *PendingResponse
  • func (p *PendingResponses) Remove(r *PendingResponse)
• type Permissions
• type PhylaxSignature
• type SignedResponse
• type User

Constants

const CCQ_SERVER_SIGNING_KEY = "CCQ SERVER SIGNING KEY"

const DEV_NETWORK_ID = "/deltaswap/dev"

const ETH_CALL_SIG_LENGTH = 4

const MAX_BODY_SIZE = 5 * 1024 * 1024

Variables

var QueryServerCmd = &cobra.Command{
	Use:   "query-server",
	Short: "Run the cross-chain query server",
	Run:   runQueryServer,
}

Functions

func FetchCurrentPhylaxSet

func FetchCurrentPhylaxSet(rpcUrl, coreAddr string) (*common.PhylaxSet, error)

func NewHTTPServer

func NewHTTPServer(addr string, t *pubsub.Topic, permissions Permissions, signerKey *ecdsa.PrivateKey, p *PendingResponses, logger *zap.Logger, env common.Environment) *http.Server

func NewStatusServer

func NewStatusServer(addr string, logger *zap.Logger, env common.Environment) *http.Server

Types

type AllowedCall

type AllowedCall struct {
	EthCall             *EthCall             `json:"ethCall"`
	EthCallByTimestamp  *EthCallByTimestamp  `json:"ethCallByTimestamp"`
	EthCallWithFinality *EthCallWithFinality `json:"ethCallWithFinality"`
}

type Config

type Config struct {
	Permissions []User `json:"Permissions"`
}

type EthCall

type EthCall struct {
	Chain           int    `json:"chain"`
	ContractAddress string `json:"contractAddress"`
	Call            string `json:"call"`
}

type EthCallByTimestamp

type EthCallByTimestamp struct {
	Chain           int    `json:"chain"`
	ContractAddress string `json:"contractAddress"`
	Call            string `json:"call"`
}

type EthCallWithFinality

type EthCallWithFinality struct {
	Chain           int    `json:"chain"`
	ContractAddress string `json:"contractAddress"`
	Call            string `json:"call"`
}

type P2PSub

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

type PendingResponse

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

func NewPendingResponse

func NewPendingResponse(req *gossipv1.SignedQueryRequest) *PendingResponse

type PendingResponses

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

func NewPendingResponses

func NewPendingResponses() *PendingResponses

func (*PendingResponses) Add

func (p *PendingResponses) Add(r *PendingResponse) bool

func (*PendingResponses) Get

func (p *PendingResponses) Get(signature string) *PendingResponse

func (*PendingResponses) Remove

func (p *PendingResponses) Remove(r *PendingResponse)

type Permissions

type Permissions map[string]*permissionEntry

type PhylaxSignature

type PhylaxSignature struct {
	Index     int
	Signature string
}

type SignedResponse

type SignedResponse struct {
	Response   *query.QueryResponsePublication
	Signatures []PhylaxSignature
}

type User

type User struct {
	UserName      string        `json:"userName"`
	ApiKey        string        `json:"apiKey"`
	AllowUnsigned bool          `json:"allowUnsigned"`
	AllowedCalls  []AllowedCall `json:"allowedCalls"`
}