server

Documentation

Index

• type ReplicationServer
  • func NewReplicationServer(ctx context.Context, log *zap.Logger, options config.ServerOptions, ...) (*ReplicationServer, error)
  • func (s *ReplicationServer) Addr() net.Addr
  • func (s *ReplicationServer) Shutdown()
  • func (s *ReplicationServer) WaitForShutdown()

Types

type ReplicationServer

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

func NewReplicationServer

func NewReplicationServer(
	ctx context.Context,
	log *zap.Logger,
	options config.ServerOptions,
	nodeRegistry registry.NodeRegistry,
	writerDB *sql.DB,
	blockchainPublisher blockchain.IBlockchainPublisher,
	listenAddress string,
) (*ReplicationServer, error)

func (*ReplicationServer) Addr

func (s *ReplicationServer) Addr() net.Addr

func (*ReplicationServer) Shutdown

func (s *ReplicationServer) Shutdown()

func (*ReplicationServer) WaitForShutdown

func (s *ReplicationServer) WaitForShutdown()