connector

Documentation

Index

• type GcpConnectorGeneric
  • func NewGeneric(BucketName string, FullFilePath string) GcpConnectorGeneric
  • func (gcp *GcpConnectorGeneric) Delete(ctx context.Context) error
  • func (gcp *GcpConnectorGeneric) GetCurrentLockId(ctx context.Context) (uuid.UUID, error)
  • func (gcp *GcpConnectorGeneric) GetLockPath(ctx context.Context) string
  • func (gcp *GcpConnectorGeneric) Lock(ctx context.Context) (uuid.UUID, error)
  • func (gcp *GcpConnectorGeneric) Read(ctx context.Context, data interface{}) error
  • func (gcp *GcpConnectorGeneric) Unlock(ctx context.Context, lockId uuid.UUID) error
  • func (gcp *GcpConnectorGeneric) WaitForlock(ctx context.Context, timeout time.Duration, existingLock ...uuid.UUID) (uuid.UUID, error)
  • func (gcp *GcpConnectorGeneric) Write(ctx context.Context, data interface{}) error
• type GcpConnectorNetwork
  • func NewNetwork(bucketName string, baseCidr string) GcpConnectorNetwork
• type NetworkConfig

Types

type GcpConnectorGeneric

type GcpConnectorGeneric struct {
	BucketName   string
	FullFilePath string
	Generation   int64
}

func NewGeneric

func NewGeneric(BucketName string, FullFilePath string) GcpConnectorGeneric

func (*GcpConnectorGeneric) Delete

func (gcp *GcpConnectorGeneric) Delete(ctx context.Context) error

func (*GcpConnectorGeneric) GetCurrentLockId

func (gcp *GcpConnectorGeneric) GetCurrentLockId(ctx context.Context) (uuid.UUID, error)

Get the current lock ID if there is one at string format and send error if there is no lock, error will be nil if there is a lock that can be retrieve

func (*GcpConnectorGeneric) GetLockPath

func (gcp *GcpConnectorGeneric) GetLockPath(ctx context.Context) string

func (*GcpConnectorGeneric) Lock

func (gcp *GcpConnectorGeneric) Lock(ctx context.Context) (uuid.UUID, error)

func (*GcpConnectorGeneric) Read

func (gcp *GcpConnectorGeneric) Read(ctx context.Context, data interface{}) error

func (*GcpConnectorGeneric) Unlock

func (gcp *GcpConnectorGeneric) Unlock(ctx context.Context, lockId uuid.UUID) error

func (*GcpConnectorGeneric) WaitForlock

func (gcp *GcpConnectorGeneric) WaitForlock(ctx context.Context, timeout time.Duration, existingLock ...uuid.UUID) (uuid.UUID, error)

Wait for lock to be relase and create a new one

func (*GcpConnectorGeneric) Write

func (gcp *GcpConnectorGeneric) Write(ctx context.Context, data interface{}) error

type GcpConnectorNetwork

type GcpConnectorNetwork struct {
	GcpConnectorGeneric
	BaseCidrRange string
}

func NewNetwork

func NewNetwork(bucketName string, baseCidr string) GcpConnectorNetwork

type NetworkConfig

type NetworkConfig struct {
	Subnets map[string]string `json:"subnets"`
}