plugin

Documentation

Overview

TODO: all plugins.

Index

• Constants
• Variables
• type AllPlugins
  • func (a *AllPlugins) String() string
• type DaprStateOprator
  • func NewDaprStateOperator(storeName string, c dapr.Client) *DaprStateOprator
  • func (o *DaprStateOprator) Create(ctx context.Context, p *model.Plugin) error
  • func (o *DaprStateOprator) Delete(ctx context.Context, pluginID string) (*model.Plugin, error)
  • func (o *DaprStateOprator) Get(ctx context.Context, pluginID string) (*model.Plugin, error)
  • func (o *DaprStateOprator) List(ctx context.Context) ([]*model.Plugin, error)
  • func (o *DaprStateOprator) Update(ctx context.Context, p *model.Plugin) error
• type Operator

Constants

const (
	KeyPrefixPlugin = "p_"
	KeyAllPlugin    = "all_plugins"
)

Variables

var (
	ErrPluginExsist          = errors.New("error plugin existed")
	ErrPluginNotExsist       = errors.New("error plugin not existed")
	ErrPluginVersionMismatch = errors.New("error plugin version mismatch")
)

Types

type AllPlugins

type AllPlugins map[string]string

func (*AllPlugins) String

func (a *AllPlugins) String() string

type DaprStateOprator

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

func NewDaprStateOperator

func NewDaprStateOperator(storeName string, c dapr.Client) *DaprStateOprator

dapr state.

func (*DaprStateOprator) Create

func (o *DaprStateOprator) Create(ctx context.Context, p *model.Plugin) error

func (*DaprStateOprator) Delete

func (o *DaprStateOprator) Delete(ctx context.Context, pluginID string) (*model.Plugin, error)

func (*DaprStateOprator) Get

func (o *DaprStateOprator) Get(ctx context.Context, pluginID string) (*model.Plugin, error)

func (*DaprStateOprator) List

func (o *DaprStateOprator) List(ctx context.Context) ([]*model.Plugin, error)

func (*DaprStateOprator) Update

func (o *DaprStateOprator) Update(ctx context.Context, p *model.Plugin) error

type Operator

type Operator interface {
	// Create plugin.
	Create(context.Context, *model.Plugin) error
	// Update plugin.
	Update(context.Context, *model.Plugin) error
	// Get plugin with the pluginID.
	Get(ctx context.Context, pluginID string) (*model.Plugin, error)
	// Delete plugin with the pluginID.
	Delete(ctx context.Context, pluginID string) (*model.Plugin, error)
	// List plugin.
	List(context.Context) ([]*model.Plugin, error)
}

Operator contains all operations to plugin.