Documentation ¶
Index ¶
- func AssureConfigFileExists() error
- func LoadConfig()
- func NewInterface(client Client) api.Interface
- func WriteConfig() error
- type ApplyInterface
- type Client
- type Config
- type ConfigServerAuthentication
- type Extension
- type ExternalFunction
- type FindParams
- type Handler
- type LambdaProcessFunc
- type Params
- type RecordProcessFunc
- type Repository
- type ServerConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AssureConfigFileExists ¶ added in v1.2.36
func AssureConfigFileExists() error
func LoadConfig ¶ added in v1.2.36
func LoadConfig()
func NewInterface ¶ added in v1.3.67
func WriteConfig ¶ added in v1.2.36
func WriteConfig() error
Types ¶
type ApplyInterface ¶
type Client ¶ added in v1.1.48
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 abs.RecordLike) (abs.RecordLike, error) UpdateRecord(ctx context.Context, namespace string, resource string, record abs.RecordLike) (abs.RecordLike, error) DeleteRecord(ctx context.Context, namespace string, name string, record abs.RecordLike) error ApplyRecord(ctx context.Context, namespace string, resource string, record abs.RecordLike) (abs.RecordLike, error) GetRecord(ctx context.Context, namespace string, resource string, id string) (abs.RecordLike, error) LoadRecord(ctx context.Context, namespace string, resource string, properties map[string]*structpb.Value, params service.RecordLoadParams) (abs.RecordLike, error) ListRecords(ctx context.Context, params service.RecordListParams) ([]abs.RecordLike, uint32, error) ListenRecords(ctx context.Context, namespace string, resource string, consumer func(records []abs.RecordLike)) error // resource GetResourceByName(ctx context.Context, namespace string, resourceName string) (*model.Resource, error) ListResources(ctx context.Context) ([]*model.Resource, error) ReadRecordStream(ctx context.Context, params service.RecordListParams, recordsChan chan abs.RecordLike) error DeleteResource(ctx context.Context, id string, doMigration bool, forceMigration bool) error CreateResource(ctx context.Context, resource *model.Resource, migration bool, force bool) error UpdateResource(ctx context.Context, resource *model.Resource, migration bool, force bool) error Watch(ctx context.Context, request *stub.WatchRequest) (stub.Watch_WatchClient, error) PollEvents(ctx context.Context, key string) (<-chan *model.Event, error) WriteEvent(ctx context.Context, key string, event *model.Event) error }
func NewClientWithConfigServer ¶ added in v1.2.21
func NewClientWithConfigServer(configServer ServerConfig) (Client, error)
func NewClientWithParams ¶ added in v1.2.21
func NewClientWithServerName ¶ added in v1.2.21
func NewLocalClient ¶ added in v1.1.37
type Config ¶ added in v1.1.39
type Config struct { Type string `yaml:"type"` Servers []ServerConfig `yaml:"servers"` DefaultServer string `yaml:"defaultServer"` }
type ConfigServerAuthentication ¶ added in v1.1.39
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.ExternalCall // contains filtered or unexported methods }
type ExternalFunction ¶
type FindParams ¶
type Handler ¶ added in v1.1.37
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 ¶ added in v1.1.37
func NewHandler[Entity interface{}](dhClient Client, ext Extension, mapper abs.EntityMapper[Entity]) Handler[Entity]
type LambdaProcessFunc ¶ added in v1.1.37
type RecordProcessFunc ¶ added in v1.1.37
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 ¶ added in v1.1.37
func R[Entity interface{}](client Client, mapper abs.EntityMapper[Entity]) Repository[Entity]
type ServerConfig ¶ added in v1.2.21
type ServerConfig struct { Host string Port uint32 // GRPC and HTTP HttpPort uint32 `yaml:"httpPort"` // If not specified, defaults to GRPC PORT Name string Authentication *ConfigServerAuthentication Insecure bool }
func LocateConfigServer ¶ added in v1.2.36
func LocateConfigServer(server string) ServerConfig
func LocateServerByName ¶ added in v1.2.36
func LocateServerByName(serverName string) ServerConfig
Click to show internal directories.
Click to hide internal directories.