internal

package

v0.0.0-...-3de6b01 Latest Latest Go to latest Published: Jul 20, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/BrobridgeOrg/gravity-dispatcher

Documentation ¶

Index ¶

Variables
func GenerateRandomString(n int) (string, error)
type ConfigEntry
- func (ce *ConfigEntry) Auth() *ConfigEntryAuth
- func (ce *ConfigEntry) Secret() *ConfigEntrySecret
type ConfigEntryAuth
type ConfigEntrySecret
type ConfigManager
- func NewConfigManager(client *core.Client, domain string) *ConfigManager
type IConfigEntry
type ProductManager
- func NewProductManager(client *core.Client, domain string) *ProductManager
type TokenManager
- func NewTokenManager(client *core.Client, domain string) *TokenManager

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrInternalSystemFailure = errors.New("internal system failure")
	ErrEventStoreNotFound    = errors.New("event store not found")
	ErrProductNotFound       = errors.New("product not found")
	ErrProductExistsAlready  = errors.New("product exists already")
	ErrInvalidProductName    = errors.New("invalid product name")
)

View Source

var (
	ErrTokenNotFound      = errors.New("token not found")
	ErrTokenExistsAlready = errors.New("token exists already")
	ErrInvalidTokenName   = errors.New("invalid token name")
)

Functions ¶

func GenerateRandomString ¶

func GenerateRandomString(n int) (string, error)

Types ¶

type ConfigEntry ¶

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

func (*ConfigEntry) Auth ¶

func (ce *ConfigEntry) Auth() *ConfigEntryAuth

func (*ConfigEntry) Secret ¶

func (ce *ConfigEntry) Secret() *ConfigEntrySecret

type ConfigEntryAuth ¶

type ConfigEntryAuth struct {
	Enabled bool `json:"enabled"`
}

type ConfigEntrySecret ¶

type ConfigEntrySecret struct {
	Key string `json:"key"`
}

Configuration entry interface

type ConfigManager ¶

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

func NewConfigManager ¶

func NewConfigManager(client *core.Client, domain string) *ConfigManager

func (*ConfigManager) GetEntry ¶

func (cm *ConfigManager) GetEntry(key string) *ConfigEntry

func (*ConfigManager) InitializeEntry ¶

func (cm *ConfigManager) InitializeEntry(key string, initialFn func() []byte) ([]byte, error)

func (*ConfigManager) SetEntry ¶

func (cm *ConfigManager) SetEntry(key string, value []byte) error

type IConfigEntry ¶

type IConfigEntry interface {
	Secret() *ConfigEntrySecret
	Auth() *ConfigEntryAuth
}

type ProductManager ¶

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

func NewProductManager ¶

func NewProductManager(client *core.Client, domain string) *ProductManager

func (*ProductManager) CreateProduct ¶

func (pm *ProductManager) CreateProduct(productSetting *product.ProductSetting) (*product.ProductSetting, error)

func (*ProductManager) DeleteProduct ¶

func (pm *ProductManager) DeleteProduct(name string) error

func (*ProductManager) GetProduct ¶

func (pm *ProductManager) GetProduct(name string) (*product.ProductSetting, error)

func (*ProductManager) GetProductState ¶

func (pm *ProductManager) GetProductState(setting *product.ProductSetting) (*product.ProductState, error)

func (*ProductManager) ListProducts ¶

func (pm *ProductManager) ListProducts() ([]*product.ProductSetting, error)

func (*ProductManager) PrepareSubscription ¶

func (pm *ProductManager) PrepareSubscription(productName string, durable string, startSeq uint64) error

func (*ProductManager) PurgeProduct ¶

func (pm *ProductManager) PurgeProduct(name string) error

func (*ProductManager) UpdateProduct ¶

func (pm *ProductManager) UpdateProduct(name string, productSetting *product.ProductSetting) (*product.ProductSetting, error)

type TokenManager ¶

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

func NewTokenManager ¶

func NewTokenManager(client *core.Client, domain string) *TokenManager

func (*TokenManager) CreateToken ¶

func (tm *TokenManager) CreateToken(t string, tokenSetting *token.TokenSetting) (*token.TokenSetting, error)

func (*TokenManager) DeleteToken ¶

func (tm *TokenManager) DeleteToken(t string) error

func (*TokenManager) GetToken ¶

func (tm *TokenManager) GetToken(t string) (*token.TokenSetting, error)

func (*TokenManager) ListTokens ¶

func (tm *TokenManager) ListTokens() ([]*token.TokenSetting, error)

func (*TokenManager) UpdateToken ¶

func (tm *TokenManager) UpdateToken(t string, tokenSetting *token.TokenSetting) (*token.TokenSetting, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL