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

v3

v3.2.2

Jun 7, 2022

v3.2.1

Jun 1, 2022

v3.2.0

May 23, 2022

v3.1.0

May 18, 2022

Changes in this version

+ const APIName

+ const APIVersion

+ 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 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

+ const VALIDATOR_ENABLED

+ const VALIDATOR_EVERY_NTH_BLOCK

+ const WATCHED_ADDRESS_GAP_FILLER_ENABLED

+ const WATCHED_ADDRESS_GAP_FILLER_INTERVAL

+ type Config struct

+ ChainConfig *params.ChainConfig

+ Client *rpc.Client

+ DB *sqlx.DB

+ DBConfig postgres.Config

+ DefaultSender *common.Address

+ EthGraphqlEnabled bool

+ EthGraphqlEndpoint string

+ EthHttpEndpoint string

+ ForwardEthCalls bool

+ GroupCache *ethServerShared.GroupCacheConfig

+ HTTPEnabled bool

+ HTTPEndpoint string

+ IPCEnabled bool

+ IPCEndpoint string

+ IpldGraphqlEnabled bool

+ IpldGraphqlEndpoint string

+ IpldPostgraphileEndpoint string

+ NodeNetworkID string

+ ProxyOnError bool

+ RPCGasCap *big.Int

+ StateValidationEnabled bool

+ StateValidationEveryNthBlock uint64

+ SupportStateDiff bool

+ TracingHttpEndpoint string

+ TracingPostgraphileEndpoint string

+ WSEnabled bool

+ WSEndpoint string

+ WatchedAddressGapFillInterval int

+ WatchedAddressGapFillerEnabled bool

+ func NewConfig() (*Config, error)

+ type Flag int32

+ const BackFillCompleteFlag

+ const EmptyFlag

+ type PublicServerAPI struct

+ func NewPublicServerAPI(w Server, client *rpc.Client) *PublicServerAPI

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

+ func (api *PublicServerAPI) WatchAddress(operation types.OperationType, args []types.WatchAddressArg) error

+ type Server interface

+ APIs func() []rpc.API

+ Backend func() *eth.Backend

+ Protocols func() []p2p.Protocol

+ Serve func(wg *sync.WaitGroup, screenAndServePayload <-chan eth.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) Backend() *eth.Backend

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

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

+ func (sap *Service) Start() 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

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