The highest tagged major version is v2.

gsharedmemory

package

v1.13.4-lux Latest Latest Go to latest Published: Jul 31, 2025 License: BSD-3-Clause Imports: 7 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/luxfi/node

Links

Open Source Insights

Documentation ¶

Index ¶

func NewSharedMemoryWrapper(sm consensus.SharedMemory) atomic.SharedMemory
type Client
- func NewClient(client sharedmemorypb.SharedMemoryClient) *Client
type ConsensusClient
- func NewConsensusClient(client sharedmemorypb.SharedMemoryClient) *ConsensusClient
type Server
- func NewServer(sm atomic.SharedMemory, db db.Database) *Server
type SharedMemoryWrapper

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewSharedMemoryWrapper ¶ added in v1.14.2

func NewSharedMemoryWrapper(sm consensus.SharedMemory) atomic.SharedMemory

NewSharedMemoryWrapper creates a new wrapper

Types ¶

type Client ¶

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

Client is atomic.SharedMemory that talks over RPC.

func NewClient ¶

func NewClient(client sharedmemorypb.SharedMemoryClient) *Client

NewClient returns shared memory connected to remote shared memory

func (*Client) Apply ¶

func (c *Client) Apply(requests map[ids.ID]*atomic.Requests, batches ...database.Batch) error

func (*Client) Get ¶

func (c *Client) Get(peerChainID ids.ID, keys [][]byte) ([][]byte, error)

func (*Client) Indexed ¶

func (c *Client) Indexed(
	peerChainID ids.ID,
	traits [][]byte,
	startTrait,
	startKey []byte,
	limit int,
) (
	[][]byte,
	[]byte,
	[]byte,
	error,
)

type ConsensusClient ¶ added in v1.14.2

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

ConsensusClient is consensus.SharedMemory that talks over RPC.

func NewConsensusClient ¶ added in v1.14.2

func NewConsensusClient(client sharedmemorypb.SharedMemoryClient) *ConsensusClient

NewConsensusClient returns shared memory connected to remote shared memory

func (*ConsensusClient) Apply ¶ added in v1.14.2

func (c *ConsensusClient) Apply(requests map[ids.ID]*consensus.Requests, batches ...interface{}) error

func (*ConsensusClient) Get ¶ added in v1.14.2

func (c *ConsensusClient) Get(peerChainID ids.ID, keys [][]byte) ([][]byte, error)

func (*ConsensusClient) Indexed ¶ added in v1.14.2

func (c *ConsensusClient) Indexed(
	peerChainID ids.ID,
	traits [][]byte,
	startTrait,
	startKey []byte,
	limit int,
) (
	[][]byte,
	[]byte,
	[]byte,
	error,
)

type Server ¶

type Server struct {
	sharedmemorypb.UnsafeSharedMemoryServer
	// contains filtered or unexported fields
}

Server is shared memory that is managed over RPC.

func NewServer ¶

func NewServer(sm atomic.SharedMemory, db db.Database) *Server

NewServer returns shared memory connected to remote shared memory

func (*Server) Apply ¶

func (s *Server) Apply(
	_ context.Context,
	req *sharedmemorypb.ApplyRequest,
) (*sharedmemorypb.ApplyResponse, error)

func (*Server) Get ¶

func (s *Server) Get(
	_ context.Context,
	req *sharedmemorypb.GetRequest,
) (*sharedmemorypb.GetResponse, error)

func (*Server) Indexed ¶

func (s *Server) Indexed(
	_ context.Context,
	req *sharedmemorypb.IndexedRequest,
) (*sharedmemorypb.IndexedResponse, error)

type SharedMemoryWrapper ¶ added in v1.14.2

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

SharedMemoryWrapper wraps consensus.SharedMemory to implement atomic.SharedMemory

func (*SharedMemoryWrapper) Apply ¶ added in v1.14.2

func (w *SharedMemoryWrapper) Apply(requests map[ids.ID]*atomic.Requests, batches ...db.Batch) error

Apply implements atomic.SharedMemory

func (*SharedMemoryWrapper) Get ¶ added in v1.14.2

func (w *SharedMemoryWrapper) Get(peerChainID ids.ID, keys [][]byte) (values [][]byte, err error)

Get implements atomic.SharedMemory

func (*SharedMemoryWrapper) Indexed ¶ added in v1.14.2

func (w *SharedMemoryWrapper) Indexed(
	peerChainID ids.ID,
	traits [][]byte,
	startTrait,
	startKey []byte,
	limit int,
) (
	values [][]byte,
	lastTrait,
	lastKey []byte,
	err error,
)

Indexed implements atomic.SharedMemory

Source Files ¶

View all Source files

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