server

package

v0.0.0-...-b4b7c53 Latest Latest Go to latest Published: Feb 10, 2024 License: GPL-3.0 Imports: 39 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cmwaters/maelstrom

Links

Open Source Insights

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)
type Server
- func New(log zerolog.Logger, config *Config, pool *tx.Pool, store *account.Store, ...) *Server

Constants ¶

View Source

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

Variables ¶

View Source

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"`
	// 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) 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.UnimplementedBlobServer
	maelstrom.UnimplementedCosmosServer
	// 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) 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) 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)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cmd
ms

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL