internal

Documentation

Index

• Variables
• func ApplyPatch(from, to []string, strat *portal.PatchStrategy) []string
• func InitLogging()
• func InitReconciler()
• func MzidToString(m *Mzid) string
• type Mzid
  • func MzidFromString(mzid string) (*Mzid, error)
• type Set
  • func NewSet(name string) *Set
  • func (s Set) AddElement(v uint64) error
  • func (s Set) Contains(v uint64) bool
  • func (s Set) DelAnyElement() (uint64, error)
  • func (s Set) DelElement(v uint64) error
  • func (s Set) GetAnyElement() (uint64, error)
  • func (s Set) Marshal() ([]byte, error)
  • func (s Set) Unmarshal(bytes []byte) error

Variables

var (
	// GRPCMaxMessageSize is the maximum message size of a grpc message
	// the option is then passed to the grpc client connection, and
	// is set in bytes.
	GRPCMaxMessageSize = 512 * 1024 * 1024
	GRPCMaxMessage     = grpc.WithDefaultCallOptions(
		grpc.MaxCallRecvMsgSize(GRPCMaxMessageSize),
		grpc.MaxCallSendMsgSize(GRPCMaxMessageSize),
	)
	GRPCMaxServer = []grpc.ServerOption{
		grpc.MaxRecvMsgSize(GRPCMaxMessageSize),
		grpc.MaxSendMsgSize(GRPCMaxMessageSize),
	}
)

var (
	MonitorEtcdServer bool = true
)

Functions

func ApplyPatch

func ApplyPatch(from, to []string, strat *portal.PatchStrategy) []string

func InitLogging

func InitLogging()

func InitReconciler

func InitReconciler()

func MzidToString

func MzidToString(m *Mzid) string

Types

type Mzid

type Mzid struct {
	Rid string
	Eid string
	Pid string
}

func MzidFromString

func MzidFromString(mzid string) (*Mzid, error)

type Set

type Set struct {
	Map  map[uint64]struct{}
	Name string
	Ver  int64
}

func NewSet

func NewSet(name string) *Set

create a new set with range [offset, offset+size) in the set

func (Set) AddElement

func (s Set) AddElement(v uint64) error

add an element to the set

func (Set) Contains

func (s Set) Contains(v uint64) bool

check for set membership

func (Set) DelAnyElement

func (s Set) DelAnyElement() (uint64, error)

delete an arbitrary element from the set and return it

func (Set) DelElement

func (s Set) DelElement(v uint64) error

delete a specific element from the set

func (Set) GetAnyElement

func (s Set) GetAnyElement() (uint64, error)

func (Set) Marshal

func (s Set) Marshal() ([]byte, error)

func (Set) Unmarshal

func (s Set) Unmarshal(bytes []byte) error