state

package

v4.99.1 Latest Latest Go to latest Published: Oct 26, 2026 License: MPL-2.0 Imports: 20 Imported by: 0

Details

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

Repository

github.com/cloudquery/plugin-sdk

Links

Open Source Insights

Documentation ¶

Index ¶

func Table(name string) *schema.Table
type Client
- func NewClient(ctx context.Context, conn *grpc.ClientConn, tableName string, opts ...Option) (*Client, error)
type Option
- func WithCheckpoints(res chan<- message.SyncMessage) Option

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Table ¶ added in v4.37.0

func Table(name string) *schema.Table

Types ¶

type Client ¶

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

func NewClient ¶

func NewClient(ctx context.Context, conn *grpc.ClientConn, tableName string, opts ...Option) (*Client, error)

func (*Client) Close ¶ added in v4.40.0

func (c *Client) Close() error

func (*Client) Flush ¶

func (c *Client) Flush(ctx context.Context) error

func (*Client) GetKey ¶

func (c *Client) GetKey(_ context.Context, key string) (string, error)

func (*Client) SetKey ¶

func (c *Client) SetKey(ctx context.Context, key string, value string) error

type Option ¶ added in v4.99.0

type Option func(*Client)

func WithCheckpoints ¶ added in v4.99.0

func WithCheckpoints(res chan<- message.SyncMessage) Option

WithCheckpoints makes Flush send the changes as message.SyncCheckpoint on res instead of writing them to the backend. Changes made within a table resolver are sent after the resources it produced before the Flush.

Source Files ¶

View all Source files

state.go

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