client

package

v1.1.3 Latest Latest Go to latest Published: Nov 3, 2026 License: ISC Imports: 20 Imported by: 0

Details

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

Repository

github.com/PlakarKorp/integration-sdk

Links

Open Source Insights

Documentation ¶

Index ¶

func NewExporter(ctx context.Context, client grpc.ClientConnInterface, ...) (integration.Exporter, error)
func NewImporter(ctx context.Context, client grpc.ClientConnInterface, ...) (integration.Importer, error)
func NewInventory(ctx context.Context, client grpc.ClientConnInterface, config map[string]string) (integration.Inventory, error)
func NewSecretProvider(ctx context.Context, conn grpc.ClientConnInterface, config map[string]string) (integration.SecretProvider, error)
func NewStorage(ctx context.Context, client grpc.ClientConnInterface, p string, ...) (integration.Store, error)
func ReceiveChunks(chunkReceiverFn func() ([]byte, error)) io.ReadCloser
func SendChunks(rd io.ReadCloser, chunkSendFn func(chunk []byte) error) (int64, error)
type Exporter
type Importer
type Store

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewExporter ¶

func NewExporter(ctx context.Context, client grpc.ClientConnInterface, opts *integration.Options, p string, config map[string]string) (integration.Exporter, error)

func NewImporter ¶

func NewImporter(ctx context.Context, client grpc.ClientConnInterface, opts *integration.Options, p string, config map[string]string) (integration.Importer, error)

func NewInventory ¶

func NewInventory(ctx context.Context, client grpc.ClientConnInterface, config map[string]string) (integration.Inventory, error)

func NewSecretProvider ¶

func NewSecretProvider(ctx context.Context, conn grpc.ClientConnInterface, config map[string]string) (integration.SecretProvider, error)

func NewStorage ¶

func NewStorage(ctx context.Context, client grpc.ClientConnInterface, p string, config map[string]string) (integration.Store, error)

func ReceiveChunks ¶

func ReceiveChunks(chunkReceiverFn func() ([]byte, error)) io.ReadCloser

func SendChunks ¶

func SendChunks(rd io.ReadCloser, chunkSendFn func(chunk []byte) error) (int64, error)

Types ¶

type Exporter ¶

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

func (*Exporter) Close ¶

func (g *Exporter) Close(ctx context.Context) error

func (*Exporter) Export ¶

func (g *Exporter) Export(ctx context.Context, records <-chan *integration.Record, results chan<- *integration.Result) error

func (*Exporter) Flags ¶

func (g *Exporter) Flags() location.Flags

func (*Exporter) Origin ¶

func (g *Exporter) Origin() string

func (*Exporter) Ping ¶

func (g *Exporter) Ping(ctx context.Context) error

func (*Exporter) Root ¶

func (g *Exporter) Root() string

func (*Exporter) Type ¶

func (g *Exporter) Type() string

type Importer ¶

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

func (*Importer) Close ¶

func (g *Importer) Close(ctx context.Context) error

func (*Importer) Flags ¶

func (g *Importer) Flags() location.Flags

func (*Importer) Import ¶

func (g *Importer) Import(ctx context.Context, records chan<- *integration.Record, results <-chan *integration.Result) error

func (*Importer) Origin ¶

func (g *Importer) Origin() string

func (*Importer) Ping ¶

func (g *Importer) Ping(ctx context.Context) error

func (*Importer) Root ¶

func (g *Importer) Root() string

func (*Importer) Type ¶

func (g *Importer) Type() string

type Store ¶

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

func (*Store) Close ¶

func (s *Store) Close(ctx context.Context) error

func (*Store) Create ¶

func (s *Store) Create(ctx context.Context, config []byte) error

func (*Store) Delete ¶

func (s *Store) Delete(ctx context.Context, res integration.StorageResource, flag integration.StorageFlag, mac integration.MAC) error

func (*Store) Flags ¶

func (s *Store) Flags() location.Flags

func (*Store) Get ¶

func (s *Store) Get(ctx context.Context, res integration.StorageResource, flag integration.StorageFlag, mac integration.MAC, rg *integration.Range) (io.ReadCloser, error)

func (*Store) List ¶

func (s *Store) List(ctx context.Context, res integration.StorageResource, flag integration.StorageFlag) iter.Seq2[integration.Resource, error]

func (*Store) Mode ¶

func (s *Store) Mode(ctx context.Context) (integration.Mode, error)

func (*Store) Open ¶

func (s *Store) Open(ctx context.Context) ([]byte, error)

func (*Store) Origin ¶

func (s *Store) Origin() string

func (*Store) Ping ¶

func (s *Store) Ping(ctx context.Context) error

func (*Store) Put ¶

func (s *Store) Put(ctx context.Context, res integration.StorageResource, flag integration.StorageFlag, mac integration.MAC, rd io.Reader) (int64, error)

func (*Store) Root ¶

func (s *Store) Root() string

func (*Store) Size ¶

func (s *Store) Size(ctx context.Context) (int64, error)

func (*Store) Type ¶

func (s *Store) Type() string

Source Files ¶

View all Source files

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