batch

Documentation

Index

• type GenericBatchBuilder
  • func NewGenericBatchBuilder(schema string, tableName string, leafHubName string) *GenericBatchBuilder
  • func (builder *GenericBatchBuilder) Build() interface{}
  • func (builder *GenericBatchBuilder) Delete(id string)
  • func (builder *GenericBatchBuilder) Insert(id string, payload interface{})
  • func (builder *GenericBatchBuilder) Update(id string, payload interface{})
• type GenericLocalBatchBuilder
  • func NewGenericLocalBatchBuilder(schema string, tableName string, leafHubName string) *GenericLocalBatchBuilder
  • func (builder *GenericLocalBatchBuilder) Build() interface{}
  • func (builder *GenericLocalBatchBuilder) Delete(id string)
  • func (builder *GenericLocalBatchBuilder) Insert(payload interface{})
  • func (builder *GenericLocalBatchBuilder) Update(payload interface{})
• type ManagedClustersBatchBuilder
  • func NewManagedClustersBatchBuilder(schema string, tableName string, leafHubName string) *ManagedClustersBatchBuilder
  • func (builder *ManagedClustersBatchBuilder) Build() interface{}
  • func (builder *ManagedClustersBatchBuilder) Delete(clusterName string)
  • func (builder *ManagedClustersBatchBuilder) Insert(clusterID string, payload interface{}, errorString string)
  • func (builder *ManagedClustersBatchBuilder) Update(clusterID string, clusterName string, payload interface{})
• type PoliciesBatchBuilder
  • func NewPoliciesBatchBuilder(schema string, tableName string, leafHubName string) *PoliciesBatchBuilder
  • func (builder *PoliciesBatchBuilder) Build() interface{}
  • func (builder *PoliciesBatchBuilder) DeleteClusterStatus(policyID string, clusterName string)
  • func (builder *PoliciesBatchBuilder) DeletePolicy(policyID string)
  • func (builder *PoliciesBatchBuilder) Insert(policyID string, clusterName string, errorString string, ...)
  • func (builder *PoliciesBatchBuilder) UpdateClusterCompliance(policyID string, clusterName string, compliance database.ComplianceStatus)
  • func (builder *PoliciesBatchBuilder) UpdatePolicyCompliance(policyID string, compliance database.ComplianceStatus)

Types

type GenericBatchBuilder

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

GenericBatchBuilder is the PostgreSQL implementation of the GenericBatchBuilder interface.

func NewGenericBatchBuilder

func NewGenericBatchBuilder(schema string, tableName string, leafHubName string) *GenericBatchBuilder

NewGenericBatchBuilder creates a new instance of PostgreSQL GenericBatchBuilder.

func (*GenericBatchBuilder) Build

func (builder *GenericBatchBuilder) Build() interface{}

Build builds the batch object.

func (*GenericBatchBuilder) Delete

func (builder *GenericBatchBuilder) Delete(id string)

Delete adds the given id to the batch to be deleted from db.

func (*GenericBatchBuilder) Insert

func (builder *GenericBatchBuilder) Insert(id string, payload interface{})

Insert adds the given (id, payload) to the batch to be inserted to the db.

func (*GenericBatchBuilder) Update

func (builder *GenericBatchBuilder) Update(id string, payload interface{})

Update adds the given (id, payload) to the batch to be updated in the db.

type GenericLocalBatchBuilder

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

GenericLocalBatchBuilder is the PostgreSQL implementation of the GenericLocalBatchBuilder interface.

func NewGenericLocalBatchBuilder

func NewGenericLocalBatchBuilder(schema string, tableName string, leafHubName string) *GenericLocalBatchBuilder

NewGenericLocalBatchBuilder creates a new instance of PostgreSQL GenericLocalBatchBuilder.

func (*GenericLocalBatchBuilder) Build

func (builder *GenericLocalBatchBuilder) Build() interface{}

Build builds the batch object.

func (*GenericLocalBatchBuilder) Delete

func (builder *GenericLocalBatchBuilder) Delete(id string)

Delete adds the given id to the batch to be deleted from db.

func (*GenericLocalBatchBuilder) Insert

func (builder *GenericLocalBatchBuilder) Insert(payload interface{})

Insert adds the given payload to the batch to be inserted to the db.

func (*GenericLocalBatchBuilder) Update

func (builder *GenericLocalBatchBuilder) Update(payload interface{})

Update adds the given payload to the batch to be updated in the db.

type ManagedClustersBatchBuilder

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

ManagedClustersBatchBuilder is the PostgreSQL implementation of the ManagedClustersBatchBuilder interface.

func NewManagedClustersBatchBuilder

func NewManagedClustersBatchBuilder(schema string, tableName string, leafHubName string) *ManagedClustersBatchBuilder

NewManagedClustersBatchBuilder creates a new instance of PostgreSQL ManagedClustersBatchBuilder.

func (*ManagedClustersBatchBuilder) Build

func (builder *ManagedClustersBatchBuilder) Build() interface{}

Build builds the batch object.

func (*ManagedClustersBatchBuilder) Delete

func (builder *ManagedClustersBatchBuilder) Delete(clusterName string)

Delete adds delete statement to the batch to delete the given cluster from db.

func (*ManagedClustersBatchBuilder) Insert

func (builder *ManagedClustersBatchBuilder) Insert(clusterID string, payload interface{}, errorString string)

Insert adds the given (cluster payload, error string) to the batch to be inserted to the db.

func (*ManagedClustersBatchBuilder) Update

func (builder *ManagedClustersBatchBuilder) Update(clusterID string, clusterName string, payload interface{})

Update adds the given arguments to the batch to update clusterName with the given payload in db.

type PoliciesBatchBuilder

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

PoliciesBatchBuilder is the PostgreSQL implementation of the PoliciesBatchBuilder interface.

func NewPoliciesBatchBuilder

func NewPoliciesBatchBuilder(schema string, tableName string, leafHubName string) *PoliciesBatchBuilder

NewPoliciesBatchBuilder creates a new instance of PostgreSQL PoliciesBatchBuilder.

func (*PoliciesBatchBuilder) Build

func (builder *PoliciesBatchBuilder) Build() interface{}

Build builds the batch object.

func (*PoliciesBatchBuilder) DeleteClusterStatus

func (builder *PoliciesBatchBuilder) DeleteClusterStatus(policyID string, clusterName string)

DeleteClusterStatus adds delete statement to the batch to delete the given (policyId,clusterName) from database.

func (*PoliciesBatchBuilder) DeletePolicy

func (builder *PoliciesBatchBuilder) DeletePolicy(policyID string)

DeletePolicy adds delete statement to the batch to delete the given policyId from database.

func (*PoliciesBatchBuilder) Insert

func (builder *PoliciesBatchBuilder) Insert(policyID string, clusterName string, errorString string,
	compliance database.ComplianceStatus,
)

Insert adds the given (policyID, clusterName, errorString, compliance) to the batch to be inserted to the database.

func (*PoliciesBatchBuilder) UpdateClusterCompliance

func (builder *PoliciesBatchBuilder) UpdateClusterCompliance(policyID string, clusterName string,
	compliance database.ComplianceStatus,
)

UpdateClusterCompliance adds the given row args to be updated in the batch.

func (*PoliciesBatchBuilder) UpdatePolicyCompliance

func (builder *PoliciesBatchBuilder) UpdatePolicyCompliance(policyID string, compliance database.ComplianceStatus)

UpdatePolicyCompliance adds the given row args to be updated in the batch.