service

type Api interface {
	Chain() *chain.Chain
	Gate() *gatewayClient
}

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

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

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

type MessageProducer interface {
	ProduceMessage(request any) error
}

type Node struct {
	ServerConfig

	PrivateKey *crypto.PrivateKey
	// contains filtered or unexported fields
}

type NodeOpts struct {
	BootstrapNodes []string
	IsMiner        bool
}

type Noder interface {
	Handshake(ctx context.Context, v *proto.Version) (*proto.Version, error)
	NewTransaction(ctx context.Context, t *proto.Transaction) (*proto.Transaction, error)
	NewBlock(ctx context.Context, b *proto.Block) (*proto.Block, error)
	GetBlocks(ctx context.Context, v *proto.Version) (*proto.Blocks, error)
}

type ServerConfig struct {
	Version              string
	NodeListenAddress    string
	ApiListenAddr        string
	GatewayAddress       string
	ConsulServiceAddress string
	StoreType            string
}