internal

Documentation

Index

• Variables
• func InitLogging()
• 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),
	}
)

Functions

func InitLogging

func InitLogging()

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