The highest tagged major version is v2.

gsharedmemory

package

v1.16.16 Latest Latest Go to latest Published: Sep 21, 2025 License: BSD-3-Clause Imports: 6 Imported by: 0

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 ¶

type Client
- func NewClient(client sharedmemorypb.SharedMemoryClient) *Client
type Server
- func NewServer(sm atomic.SharedMemory, db database.Database) *Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 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 database.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)

Source Files ¶

View all Source files

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