server

Documentation

Index

• Constants
• Variables
• func CancelRequestSignOverData(signer string, txID uint64) []byte
• func EstimateMinGas(blobSizes []uint32) uint64
• func SubmitRequestSignOverData(namespace []byte, blobs [][]byte) []byte
• func WithdrawRequestSignOverData(signer string, balance, amount, timestamp uint64) []byte
• type Config
  • func DefaultConfig() *Config
  • func LoadConfig(path string) (*Config, error)
  • func (cfg *Config) GenerateKey() (sdk.AccAddress, string, error)
  • func (cfg *Config) GetRecord() (*keyring.Record, error)
  • func (cfg *Config) HomeDir() string
  • func (cfg *Config) ImportKey(mnemonic string) (sdk.AccAddress, error)
  • func (cfg *Config) Keyring() (keyring.Keyring, error)
  • func (cfg *Config) KeyringDir() string
  • func (cfg *Config) NewServer(ctx context.Context) (*Server, error)
  • func (c *Config) Save(path string) error
  • func (cfg *Config) StoreDir() string
  • func (cfg *Config) WithDir(dir string) *Config
  • func (cfg *Config) WithKeyring(kr keyring.Keyring) *Config
• type Server
  • func New(log zerolog.Logger, config *Config, pool *tx.Pool, store *account.Store, ...) *Server
  • func (s *Server) AccountInfo(ctx context.Context, req *maelstrom.AccountInfoRequest) (*maelstrom.AccountInfoResponse, error)
  • func (s *Server) Balance(ctx context.Context, req *maelstrom.BalanceRequest) (*maelstrom.BalanceResponse, error)
  • func (s *Server) BroadcastTx(ctx context.Context, req *maelstrom.BroadcastTxRequest) (*maelstrom.BroadcastTxResponse, error)
  • func (s *Server) Cancel(ctx context.Context, req *maelstrom.CancelRequest) (*maelstrom.CancelResponse, error)
  • func (s *Server) Info(ctx context.Context, req *maelstrom.InfoRequest) (*maelstrom.InfoResponse, error)
  • func (s *Server) PendingWithdrawal(ctx context.Context, req *maelstrom.PendingWithdrawalRequest) (*maelstrom.PendingWithdrawalResponse, error)
  • func (s *Server) Serve(ctx context.Context) error
  • func (s *Server) SetLogger(log zerolog.Logger)
  • func (s *Server) Status(ctx context.Context, req *maelstrom.StatusRequest) (*maelstrom.StatusResponse, error)
  • func (s *Server) Submit(ctx context.Context, req *maelstrom.SubmitRequest) (*maelstrom.SubmitResponse, error)
  • func (s *Server) WaitUntilReady(ctx context.Context) error
  • func (s *Server) Withdraw(ctx context.Context, req *maelstrom.WithdrawRequest) (*maelstrom.WithdrawResponse, error)

Constants

const (
	ConfigFileName = "config.toml"
	KeyringDirName = "keys"
	DefaultKeyName = StoreName
	StoreName      = "maelstrom"
)

Variables

var ErrServerNotReady = errors.New("server not ready")

Functions

func CancelRequestSignOverData

func CancelRequestSignOverData(signer string, txID uint64) []byte

func EstimateMinGas

func EstimateMinGas(blobSizes []uint32) uint64

func SubmitRequestSignOverData

func SubmitRequestSignOverData(namespace []byte, blobs [][]byte) []byte

func WithdrawRequestSignOverData

func WithdrawRequestSignOverData(signer string, balance, amount, timestamp uint64) []byte

Types

type Config

type Config struct {
	GRPCServerAddress   string `toml:"grpc_server_address"`
	GRPCGatewayAddress  string `toml:"grpc_gateway_address"`
	CelestiaRPCAddress  string `toml:"celestia_rpc_address"`
	CelestiaGRPCAddress string `toml:"celestia_grpc_address"`

	KeyringName   string        `toml:"keyring_name"`
	TimeoutCommit time.Duration `toml:"timeout_commit"`
	StartHeight   uint64        `toml:"start_height"`
	// contains filtered or unexported fields
}

func DefaultConfig

func DefaultConfig() *Config

func LoadConfig

func LoadConfig(path string) (*Config, error)

func (*Config) GenerateKey

func (cfg *Config) GenerateKey() (sdk.AccAddress, string, error)

func (*Config) GetRecord

func (cfg *Config) GetRecord() (*keyring.Record, error)

func (*Config) HomeDir

func (cfg *Config) HomeDir() string

func (*Config) ImportKey

func (cfg *Config) ImportKey(mnemonic string) (sdk.AccAddress, error)

func (*Config) Keyring

func (cfg *Config) Keyring() (keyring.Keyring, error)

func (*Config) KeyringDir

func (cfg *Config) KeyringDir() string

func (*Config) NewServer

func (cfg *Config) NewServer(ctx context.Context) (*Server, error)

func (*Config) Save

func (c *Config) Save(path string) error

func (*Config) StoreDir

func (cfg *Config) StoreDir() string

func (*Config) WithDir

func (cfg *Config) WithDir(dir string) *Config

func (*Config) WithKeyring

func (cfg *Config) WithKeyring(kr keyring.Keyring) *Config

type Server

type Server struct {
	maelstrom.UnimplementedMaelstromServer
	// contains filtered or unexported fields
}

func New

func New(
	log zerolog.Logger,
	config *Config,
	pool *tx.Pool,
	store *account.Store,
	keys keyring.Keyring,
	address sdk.AccAddress,
) *Server

func (*Server) AccountInfo

func (s *Server) AccountInfo(ctx context.Context, req *maelstrom.AccountInfoRequest) (*maelstrom.AccountInfoResponse, error)

func (*Server) Balance

func (s *Server) Balance(ctx context.Context, req *maelstrom.BalanceRequest) (*maelstrom.BalanceResponse, error)

func (*Server) BroadcastTx

func (s *Server) BroadcastTx(ctx context.Context, req *maelstrom.BroadcastTxRequest) (*maelstrom.BroadcastTxResponse, error)

BroadcastTx broadcast transaction.

func (*Server) Cancel

func (s *Server) Cancel(ctx context.Context, req *maelstrom.CancelRequest) (*maelstrom.CancelResponse, error)

func (*Server) Info

func (s *Server) Info(ctx context.Context, req *maelstrom.InfoRequest) (*maelstrom.InfoResponse, error)

func (*Server) PendingWithdrawal

func (s *Server) PendingWithdrawal(ctx context.Context, req *maelstrom.PendingWithdrawalRequest) (*maelstrom.PendingWithdrawalResponse, error)

func (*Server) Serve

func (s *Server) Serve(ctx context.Context) error

func (*Server) SetLogger

func (s *Server) SetLogger(log zerolog.Logger)

SetLogger sets the logger for the server. Must be called prior to starting the server

func (*Server) Status

func (s *Server) Status(ctx context.Context, req *maelstrom.StatusRequest) (*maelstrom.StatusResponse, error)

func (*Server) Submit

func (s *Server) Submit(ctx context.Context, req *maelstrom.SubmitRequest) (*maelstrom.SubmitResponse, error)

func (*Server) WaitUntilReady

func (s *Server) WaitUntilReady(ctx context.Context) error

func (*Server) Withdraw

func (s *Server) Withdraw(ctx context.Context, req *maelstrom.WithdrawRequest) (*maelstrom.WithdrawResponse, error)