reconcile

Documentation

Index

• func Entries(ctx context.Context, logger kitlog.Logger, cl EntriesClient, ...) error
• func GetEntries(ctx context.Context, cl *client.ClientWithResponses, catalogTypeID string) (catalogType *client.CatalogTypeV2, entries []client.CatalogEntryV2, err error)
• type EntriesClient
  • func EntriesClientFromClient(cl *client.ClientWithResponses) EntriesClient
• type EntriesProgress

Functions

func Entries

func Entries(ctx context.Context, logger kitlog.Logger, cl EntriesClient, catalogType *client.CatalogTypeV2, entryModels []*output.CatalogEntryModel, progress *EntriesProgress) error

func GetEntries

func GetEntries(ctx context.Context, cl *client.ClientWithResponses, catalogTypeID string) (catalogType *client.CatalogTypeV2, entries []client.CatalogEntryV2, err error)

GetEntries paginates through all catalog entries for the given type.

Types

type EntriesClient

type EntriesClient struct {
	GetEntries func(ctx context.Context, catalogTypeID string) (*client.CatalogTypeV2, []client.CatalogEntryV2, error)
	Delete     func(ctx context.Context, entry *client.CatalogEntryV2) error
	Create     func(ctx context.Context, payload client.CreateEntryRequestBody) (*client.CatalogEntryV2, error)
	Update     func(ctx context.Context, entry *client.CatalogEntryV2, payload client.UpdateEntryRequestBody) (*client.CatalogEntryV2, error)
}

func EntriesClientFromClient

func EntriesClientFromClient(cl *client.ClientWithResponses) EntriesClient

EntriesClientFromClient wraps a real client with hooks that can create, update and delete entries. This can be overriden for custom behaviour, such as a dry-run that shouldn't actually perform updates.

type EntriesProgress

type EntriesProgress struct {
	OnDeleteStart    func(total int)
	OnDeleteProgress func()
	OnCreateStart    func(total int)
	OnCreateProgress func()
	OnUpdateStart    func(total int)
	OnUpdateProgress func()
}