client

Documentation

Index

• type ApplyInterface
• type Client
  • func NewDhClient(params DhClientParams) (Client, error)
  • func NewDhClientLocal(serverName string) (Client, error)
  • func NewLocalClient(container service.Container) Client
• type Config
• type ConfigServer
• type ConfigServerAuthentication
• type DhClientParams
• type Extension
• type ExternalFunction
• type FindParams
• type Handler
  • func NewHandler[Entity interface{}](dhClient Client, ext Extension, mapper abs.EntityMapper[Entity]) Handler[Entity]
• type LambdaProcessFunc
• type RecordProcessFunc
• type Repository
  • func NewRepository[Entity interface{}](client Client, mapper abs.EntityMapper[Entity]) Repository[Entity]
  • func R[Entity interface{}](client Client, mapper abs.EntityMapper[Entity]) Repository[Entity]

Types

type ApplyInterface

type ApplyInterface interface {
	ApplyResource(ctx context.Context, resource *model.Resource, doMigration, forceMigration bool) error
}

type Client

type Client interface {
	ApplyInterface
	AuthenticateWithToken(token string)
	AuthenticateWithUsernameAndPassword(username string, password string) error
	NewRemoteExtension(host string, remoteHost string) Extension
	NewPollExtension() Extension
	UpdateTokenFromContext(ctx context.Context)

	// record
	CreateRecord(ctx context.Context, namespace string, resource string, record *model.Record) (*model.Record, error)
	UpdateRecord(ctx context.Context, namespace string, resource string, record *model.Record) (*model.Record, error)
	ApplyRecord(ctx context.Context, namespace string, resource string, record *model.Record) (*model.Record, error)
	GetRecord(ctx context.Context, namespace string, resource string, id string) (*model.Record, error)
	ListRecords(ctx context.Context, params service.RecordListParams) ([]*model.Record, uint32, error)
	ListenRecords(ctx context.Context, namespace string, resource string, consumer func(records []*model.Record)) error

	// resource
	GetResourceByName(ctx context.Context, namespace string, getType string) (*model.Resource, error)
	ListResources(ctx context.Context) ([]*model.Resource, error)
	ReadRecordStream(ctx context.Context, params service.RecordListParams, recordsChan chan *model.Record) error
	DeleteResource(ctx context.Context, id string, doMigration bool, forceMigration bool) error

	PollEvents(ctx context.Context, key string) (<-chan *model.Event, error)
	WriteEvent(ctx context.Context, key string, event *model.Event) error
}

func NewDhClient

func NewDhClient(params DhClientParams) (Client, error)

func NewDhClientLocal

func NewDhClientLocal(serverName string) (Client, error)

func NewLocalClient

func NewLocalClient(container service.Container) Client

type Config

type Config struct {
	Type          string
	Servers       []ConfigServer
	DefaultServer string
}

type ConfigServer

type ConfigServer struct {
	Host           string
	Name           string
	Authentication ConfigServerAuthentication
	Insecure       bool
}

type ConfigServerAuthentication

type ConfigServerAuthentication struct {
	Username string
	Password string
	Token    string
}

type DhClientParams

type DhClientParams struct {
	Addr     string
	Insecure bool
	Token    string
}

type Extension

type Extension interface {
	Run(ctx context.Context) error
	RegisterFunction(s string, f ExternalFunction)
	RegisterExtension(newExtension *resource_model.Extension)

	WithServiceKey(serviceKey string) Extension
	PrepareCall(*resource_model.Extension) resource_model.ExtensionExternalCall
	// contains filtered or unexported methods
}

type ExternalFunction

type ExternalFunction func(ctx context.Context, req *model.Event) (*model.Event, error)

type FindParams

type FindParams struct {
	Limit             uint32
	Offset            uint64
	UseHistory        bool
	Annotations       map[string]string
	ResolveReferences []string
	Query             *model.BooleanExpression
}

type Handler

type Handler[Entity interface{}] interface {
	Name(string) Handler[Entity]
	Before() Handler[Entity]
	PreProcess(RecordProcessFunc[Entity]) Handler[Entity]
	PostProcess(RecordProcessFunc[Entity]) Handler[Entity]
	Lambda(action string, processor LambdaProcessFunc[Entity]) Handler[Entity]
	Fire(ctx context.Context, action string, payload Entity) error
	After() Handler[Entity]
	Instead() Handler[Entity]
	Create(RecordProcessFunc[Entity]) Handler[Entity]
	Update(RecordProcessFunc[Entity]) Handler[Entity]
	Delete(RecordProcessFunc[Entity]) Handler[Entity]
}

func NewHandler

func NewHandler[Entity interface{}](dhClient Client, ext Extension, mapper abs.EntityMapper[Entity]) Handler[Entity]

type LambdaProcessFunc

type LambdaProcessFunc[Entity interface{}] func(ctx context.Context, event *model.Event, instance Entity) error

type RecordProcessFunc

type RecordProcessFunc[Entity interface{}] func(ctx context.Context, event *model.Event, instance Entity) (Entity, error)

type Repository

type Repository[Entity interface{}] interface {
	Mapper() abs.EntityMapper[Entity]
	Create(ctx context.Context, entity Entity) (Entity, error)
	Update(ctx context.Context, entity Entity) (Entity, error)
	Apply(ctx context.Context, entity Entity) (Entity, error)
	Get(ctx context.Context, id string) (Entity, error)
	Find(ctx context.Context, params FindParams) ([]Entity, uint32, error)
	Listen(ctx context.Context, consumer func(records []Entity)) error
}

func NewRepository

func NewRepository[Entity interface{}](client Client, mapper abs.EntityMapper[Entity]) Repository[Entity]

func R

func R[Entity interface{}](client Client, mapper abs.EntityMapper[Entity]) Repository[Entity]