relation_manager_postgres

package

v0.0.2 Latest Latest Go to latest Published: Oct 12, 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/weedbox/bursary

Links

Open Source Insights

README ¶

RelationManagerPostgres

The RelationManagerPostgres is the Bursary RelationManager implementation based on the PostgreSQL database system.

Documentation ¶

Index ¶

Constants
type ChannelRules
- func (cr *ChannelRules) Scan(src interface{}) error
- func (cr ChannelRules) Value() (driver.Value, error)
type MemberRecord
- func (mr *MemberRecord) ToMemberObject() *bursary.Member
type Opt
- func WithDb(db *sqlx.DB) Opt
- func WithTableName(tableName string) Opt
type RelationManagerPostgres
- func NewRelationManagerPostgres(opts ...Opt) *RelationManagerPostgres
type Rule

Constants ¶

View Source

const RootNode = "00000000-0000-0000-0000-000000000000"

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ChannelRules ¶

type ChannelRules map[string]*Rule

func (*ChannelRules) Scan ¶

func (cr *ChannelRules) Scan(src interface{}) error

func (ChannelRules) Value ¶

func (cr ChannelRules) Value() (driver.Value, error)

type MemberRecord ¶

type MemberRecord struct {
	ID           string         `db:"id"`
	ChannelRules ChannelRules   `db:"channel_rules"`
	RelationPath pq.StringArray `db:"relation_path"`
	Upstream     string         `db:"upstream"`
	CreatedAt    time.Time      `db:"created_at"`
}

func (*MemberRecord) ToMemberObject ¶

func (mr *MemberRecord) ToMemberObject() *bursary.Member

type Opt ¶

type Opt func(*RelationManagerPostgres)

func WithDb ¶

func WithDb(db *sqlx.DB) Opt

func WithTableName ¶

func WithTableName(tableName string) Opt

type RelationManagerPostgres ¶

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

func NewRelationManagerPostgres ¶

func NewRelationManagerPostgres(opts ...Opt) *RelationManagerPostgres

func (*RelationManagerPostgres) AddMembers ¶

func (rm *RelationManagerPostgres) AddMembers(members []*bursary.MemberEntry, upstream string) error

func (*RelationManagerPostgres) ChangePath ¶

func (rm *RelationManagerPostgres) ChangePath(mid string, newPath []string) error

func (*RelationManagerPostgres) ChangePathByUpstream ¶

func (rm *RelationManagerPostgres) ChangePathByUpstream(upstream string, newPath []string) error

func (*RelationManagerPostgres) Close ¶

func (rm *RelationManagerPostgres) Close() error

func (*RelationManagerPostgres) DeleteMembers ¶

func (rm *RelationManagerPostgres) DeleteMembers(mids []string) error

func (*RelationManagerPostgres) GetMember ¶

func (rm *RelationManagerPostgres) GetMember(mid string) (*bursary.Member, error)

func (*RelationManagerPostgres) GetPath ¶

func (rm *RelationManagerPostgres) GetPath(mid string) ([]string, error)

func (*RelationManagerPostgres) GetUpstreams ¶

func (rm *RelationManagerPostgres) GetUpstreams(mid string) ([]*bursary.Member, error)

func (*RelationManagerPostgres) Init ¶

func (rm *RelationManagerPostgres) Init() error

func (*RelationManagerPostgres) ListMembers ¶

func (rm *RelationManagerPostgres) ListMembers(upstream string, cond *bursary.Condition) ([]*bursary.Member, error)

func (*RelationManagerPostgres) MoveMembers ¶

func (rm *RelationManagerPostgres) MoveMembers(mids []string, upstream string) error

func (*RelationManagerPostgres) RemoveChannel ¶

func (rm *RelationManagerPostgres) RemoveChannel(channel string) error

func (*RelationManagerPostgres) RemoveChannelRule ¶

func (rm *RelationManagerPostgres) RemoveChannelRule(mid string, channel string) error

func (*RelationManagerPostgres) UpdateChannelRule ¶

func (rm *RelationManagerPostgres) UpdateChannelRule(mid string, channel string, rule *bursary.Rule) error

type Rule ¶

type Rule struct {
	Commission float64 `json:"commission"`
	Share      float64 `json:"share"`
}

Source Files ¶

View all Source files

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