mongo

Documentation

Overview

Package mongo implements Mserv MongoDB storage.

Index

• Variables
• type Config
• type MgoStoreConf
• type Store
  • func (m *Store) CreateMW(ctx context.Context, mw *storage.MW) (string, error)
  • func (m *Store) DeleteMW(ctx context.Context, id string) error
  • func (m *Store) GetAllActive(ctx context.Context) ([]*storage.MW, error)
  • func (m *Store) GetMWByAPIID(ctx context.Context, apiID string) (*storage.MW, error)
  • func (m *Store) GetMWByID(ctx context.Context, id string) (*storage.MW, error)
  • func (m *Store) GetTag() string
  • func (m *Store) Health() map[string]interface{}
  • func (m *Store) Init() error
  • func (m *Store) InitMservStore(_ context.Context, tag string) error
  • func (m *Store) SetTag(tag string)
  • func (m *Store) UpdateMW(ctx context.Context, mw *storage.MW) (string, error)

Variables

var (
	// ErrEmptyUID is returned when middleware UID is empty.
	ErrEmptyUID = errors.New("UID cannot be empty")

	// ErrNotFound is returned when middleware is not found.
	ErrNotFound = errors.New("middleware not found")
)

var GetConf = func() *Config {
	if sconf == nil {
		sconf = &Config{}

		err := json.Unmarshal(conf.ReadConf(), sconf)
		if err != nil {
			log.Fatal("Failed to unmarshal mongo driver config: ", err)
		}
	}

	return sconf
}

Types

type Config

type Config struct {
	MongoStore map[string]*MgoStoreConf
}

type MgoStoreConf

type MgoStoreConf struct {
	ConnStr string
}

type Store

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

func (*Store) CreateMW

func (m *Store) CreateMW(ctx context.Context, mw *storage.MW) (string, error)

CreateMW stores the given middleware.

func (*Store) DeleteMW

func (m *Store) DeleteMW(ctx context.Context, id string) error

DeleteMW removes given middleware.

func (*Store) GetAllActive

func (m *Store) GetAllActive(ctx context.Context) ([]*storage.MW, error)

GetAllActive returns all active middleware from the store.

func (*Store) GetMWByAPIID

func (m *Store) GetMWByAPIID(ctx context.Context, apiID string) (*storage.MW, error)

GetMWByAPIID gets middleware from the store based on its API ID.

func (*Store) GetMWByID

func (m *Store) GetMWByID(ctx context.Context, id string) (*storage.MW, error)

GetMWByID gets middleware from the store based on its UID.

func (*Store) GetTag

func (m *Store) GetTag() string

func (*Store) Health

func (m *Store) Health() map[string]interface{}

func (*Store) Init

func (m *Store) Init() error

func (*Store) InitMservStore

func (m *Store) InitMservStore(_ context.Context, tag string) error

InitMservStore initializes Mserv storage.

func (*Store) SetTag

func (m *Store) SetTag(tag string)

func (*Store) UpdateMW

func (m *Store) UpdateMW(ctx context.Context, mw *storage.MW) (string, error)

UpdateMW will update the given middleware in-place in storage.