Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

serve

package

Go to main page

Versions in this module

v0

v0.3.9

Dec 30, 2021

Changes in this version

+ const DATABASE_HOSTNAME

+ const DATABASE_MAX_CONN_LIFETIME

+ const DATABASE_MAX_IDLE_CONNECTIONS

+ const DATABASE_MAX_OPEN_CONNECTIONS

+ const DATABASE_NAME

+ const DATABASE_PASSWORD

+ const DATABASE_PORT

+ const DATABASE_USER

+ const ETH_CHAIN_CONFIG

+ const ETH_CHAIN_ID

+ const ETH_CLIENT_NAME

+ const ETH_DEFAULT_SENDER_ADDR

+ const ETH_FORWARD_ETH_CALLS

+ const ETH_GENESIS_BLOCK

+ const ETH_HTTP_PATH

+ const ETH_NETWORK_ID

+ const ETH_NODE_ID

+ const ETH_PROXY_ON_ERROR

+ const ETH_RPC_GAS_CAP

+ const ETH_SUPPORTS_STATEDIFF

+ const ETH_WS_PATH

+ const HTTP_TIMEOUT

+ const VALIDATOR_ENABLED

+ const VALIDATOR_EVERY_NTH_BLOCK

type Config

+ ChainConfig *params.ChainConfig

+ Client *rpc.Client

+ DBParams postgres.ConnectionParams

+ DefaultSender *common.Address

+ EthGraphqlEnabled bool

+ EthGraphqlEndpoint string

+ EthHttpEndpoint string

+ ForwardEthCalls bool

+ GroupCache *ethServerShared.GroupCacheConfig

+ HTTPEnabled bool

+ IPCEnabled bool

+ IpldGraphqlEnabled bool

+ IpldGraphqlEndpoint string

+ IpldPostgraphileEndpoint string

+ ProxyOnError bool

+ RPCGasCap *big.Int

+ StateValidationEnabled bool

+ StateValidationEveryNthBlock uint64

+ SupportStateDiff bool

+ TracingHttpEndpoint string

+ TracingPostgraphileEndpoint string

+ WSEnabled bool

type Server

+ APIs func() []rpc.API

+ Backend func() *eth.Backend

+ Protocols func() []p2p.Protocol

type Service

+ func (sap *Service) Backend() *eth.Backend

v0.3.8-alpha

Oct 21, 2021

v0.3.7-alpha

Oct 12, 2021

v0.3.6-alpha

Aug 12, 2021

v0.3.5-alpha

Apr 11, 2021

v0.3.4-alpha

Mar 19, 2021

v0.3.3-alpha

Mar 10, 2021

v0.3.2-alpha

Mar 10, 2021

v0.3.1-alpha

Feb 27, 2021

v0.3.0-alpha

Feb 19, 2021

v0.2.0-alpha

Nov 13, 2020

v0.1.0-alpha

Oct 21, 2020

v0.0.13

Sep 11, 2020

v0.0.12

Sep 9, 2020

Changes in this version

+ const APIName

+ const APIVersion

+ const PayloadChanBufferSize

+ const SERVER_HTTP_PATH

+ const SERVER_IPC_PATH

+ const SERVER_MAX_CONN_LIFETIME

+ const SERVER_MAX_IDLE_CONNECTIONS

+ const SERVER_MAX_OPEN_CONNECTIONS

+ const SERVER_WS_PATH

+ type Config struct

+ DB *postgres.DB

+ DBConfig postgres.Config

+ HTTPEndpoint string

+ IPCEndpoint string

+ WSEndpoint string

+ func NewConfig() (*Config, error)

+ type Flag int32

+ const BackFillCompleteFlag

+ const EmptyFlag

+ type InfoAPI struct

+ func NewInfoAPI() *InfoAPI

+ func (iapi *InfoAPI) Modules() map[string]string

+ func (iapi *InfoAPI) NodeInfo() *p2p.NodeInfo

+ func (iapi *InfoAPI) Version() string

+ type PublicServerAPI struct

+ func NewPublicServerAPI(w Server) *PublicServerAPI

+ func (api *PublicServerAPI) Chain() shared.ChainType

+ func (api *PublicServerAPI) Stream(ctx context.Context, params eth.SubscriptionSettings) (*rpc.Subscription, error)

+ type Server interface

+ Chain func() shared.ChainType

+ Serve func(wg *sync.WaitGroup, screenAndServePayload <-chan eth2.ConvertedPayload)

+ Subscribe func(id rpc.ID, sub chan<- SubscriptionPayload, quitChan chan<- bool, ...)

+ Unsubscribe func(id rpc.ID)

+ func NewServer(settings *Config) (Server, error)

+ type Service struct

+ Filterer eth.Filterer

+ IPLDFetcher eth.Fetcher

+ QuitChan chan bool

+ Retriever eth.Retriever

+ SubscriptionTypes map[common.Hash]eth.SubscriptionSettings

+ Subscriptions map[common.Hash]map[rpc.ID]Subscription

+ func (sap *Service) APIs() []rpc.API

+ func (sap *Service) Chain() shared.ChainType

+ func (sap *Service) Protocols() []p2p.Protocol

+ func (sap *Service) Serve(wg *sync.WaitGroup, screenAndServePayload <-chan eth2.ConvertedPayload)

+ func (sap *Service) Start(*p2p.Server) error

+ func (sap *Service) Stop() error

+ func (sap *Service) Subscribe(id rpc.ID, sub chan<- SubscriptionPayload, quitChan chan<- bool, ...)

+ func (sap *Service) Unsubscribe(id rpc.ID)

+ type Subscription struct

+ ID rpc.ID

+ PayloadChan chan<- SubscriptionPayload

+ QuitChan chan<- bool

+ type SubscriptionPayload struct

+ Data []byte

+ Err string

+ Flag Flag

+ Height int64

+ func (sp SubscriptionPayload) BackFillComplete() bool

+ func (sp SubscriptionPayload) Error() error

Other modules containing this package

github.com/vulcanize/ipld-eth-server/v3

github.com/vulcanize/ipld-eth-server/v4