entx

Documentation

Index

• type ClientSet
  • func NewClientSet(primary *ent.Client, opts ...ClientSetOption) *ClientSet
  • func (c *ClientSet) Close() error
  • func (c *ClientSet) Primary() *ent.Client
  • func (c *ClientSet) Replica() *ent.Client
• type ClientSetOption
  • func WithPolicy(policy Policy) ClientSetOption
  • func WithReplicas(replicas []*ent.Client) ClientSetOption
• type ClientType
• type Policy
• type RandomClientSetPolicy
  • func (p *RandomClientSetPolicy) Resolve(clients []*ent.Client) *ent.Client
• type RoundRobinPolicy
  • func (p *RoundRobinPolicy) Resolve(clients []*ent.Client) *ent.Client

Types

type ClientSet

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

func NewClientSet

func NewClientSet(primary *ent.Client, opts ...ClientSetOption) *ClientSet

func (*ClientSet) Close

func (c *ClientSet) Close() error

func (*ClientSet) Primary

func (c *ClientSet) Primary() *ent.Client

func (*ClientSet) Replica

func (c *ClientSet) Replica() *ent.Client

type ClientSetOption

type ClientSetOption func(*ClientSet)

func WithPolicy

func WithPolicy(policy Policy) ClientSetOption

func WithReplicas

func WithReplicas(replicas []*ent.Client) ClientSetOption

type ClientType

type ClientType int

type Policy

type Policy interface {
	Resolve([]*ent.Client) *ent.Client
}

type RandomClientSetPolicy

type RandomClientSetPolicy struct{}

func (*RandomClientSetPolicy) Resolve

func (p *RandomClientSetPolicy) Resolve(clients []*ent.Client) *ent.Client

type RoundRobinPolicy

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

func (*RoundRobinPolicy) Resolve

func (p *RoundRobinPolicy) Resolve(clients []*ent.Client) *ent.Client