dms

Documentation

Index

• Constants
• Variables
• type ContextIndex
• type Dms
  • func NewKafkaDms(brokers []string, handler ReceiveHandler, servedEntity *Entity) (*Dms, error)
  • func NewNatsDms(natsUrl, clusterId, clientId string, handler ReceiveHandler, ...) (*Dms, error)
  • func (d *Dms) Close() error
  • func (d *Dms) Run(ctx context.Context) error
  • func (d *Dms) SendMessage(srcKey, dstKey EntityKey, payload []byte) error
• type Entity
  • func NewEntity(className string, objectName string, tokenType TokenType, ...) *Entity
  • func (e Entity) NewEntityKey(tokenIndex, ctxIndex uint64) *EntityKey
  • func (e Entity) NewPublicEntityKey() *EntityKey
  • func (e Entity) NewRandomEntityKey() *EntityKey
• type EntityKey
  • func NewEntityKey(tokenType, tokenIndex, ctxIndex uint64) *EntityKey
  • func NewPublicEntityKey(tokenType TokenType) *EntityKey
  • func (e *EntityKey) AtoI(s string) *EntityKey
  • func (e EntityKey) ContextIndex() ContextIndex
  • func (e EntityKey) IsPublicEntityKey() bool
  • func (e *EntityKey) ItoA() string
  • func (e EntityKey) MapToTopic() string
  • func (e *EntityKey) SetContextIndex(ctxIndex ContextIndex) *EntityKey
  • func (e *EntityKey) SetToken(token Token) *EntityKey
  • func (e *EntityKey) SetTokenIndex(tokenIndex TokenIndex) *EntityKey
  • func (e *EntityKey) SetTokenType(tokenType TokenType) *EntityKey
  • func (e EntityKey) Token() Token
  • func (e EntityKey) TokenIndex() TokenIndex
  • func (e EntityKey) TokenType() TokenType
• type ReceiveHandler
• type Token
• type TokenIndex
• type TokenType

Constants

const (
	TokenTypeSmf  TokenType = 0x5000
	TokenTypeSbim TokenType = 0x6000
	TokenTypeUdm  TokenType = 0x7000
	TokenTypeChf  TokenType = 0x8000

	MinStartToken     = 1
	MaxEndToken       = 100
	DefaultStartToken = 1
	DefaultEndToken   = 10
)

const NullEntityKey = uint64(0)

Variables

var (
	DefaultSrcSmfEntity  = NewEntity("smf", "smf1", TokenTypeSmf, DefaultStartToken, DefaultEndToken)
	DefaultSrcSbimEntity = NewEntity("sbim", "sbim1", TokenTypeSbim, DefaultStartToken, DefaultEndToken)
	DefaultSrcUdmEntity  = NewEntity("udm", "udm1", TokenTypeUdm, DefaultStartToken, DefaultEndToken)
	DefaultSrcChfEntity  = NewEntity("chf", "chf1", TokenTypeChf, DefaultStartToken, DefaultEndToken)

	DefaultDstSmfEntity  = NewEntity("smf", "smf1", TokenTypeSmf, MinStartToken, MaxEndToken)
	DefaultDstSbimEntity = NewEntity("sbim", "sbim1", TokenTypeSbim, MinStartToken, MaxEndToken)
	DefaultDstUdmEntity  = NewEntity("udm", "udm1", TokenTypeUdm, MinStartToken, MaxEndToken)
	DefaultDstChfEntity  = NewEntity("chf", "chf1", TokenTypeChf, MinStartToken, MaxEndToken)
)

Types

type ContextIndex

type ContextIndex uint64

type Dms

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

func NewKafkaDms

func NewKafkaDms(brokers []string, handler ReceiveHandler, servedEntity *Entity) (*Dms, error)

func NewNatsDms

func NewNatsDms(natsUrl, clusterId, clientId string, handler ReceiveHandler, servedEntity *Entity) (*Dms, error)

func (*Dms) Close

func (d *Dms) Close() error

func (*Dms) Run

func (d *Dms) Run(ctx context.Context) error

Run blocked after running

func (*Dms) SendMessage

func (d *Dms) SendMessage(srcKey, dstKey EntityKey, payload []byte) error

type Entity

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

func NewEntity

func NewEntity(className string, objectName string, tokenType TokenType, startToken, endToken uint64) *Entity

NewEntity if the Entity is source of Dms, startToken and endToken is the instance where the entity is located, if the Entity is destination of Dms, startToken is min, endToken is max

func (Entity) NewEntityKey

func (e Entity) NewEntityKey(tokenIndex, ctxIndex uint64) *EntityKey

func (Entity) NewPublicEntityKey

func (e Entity) NewPublicEntityKey() *EntityKey

func (Entity) NewRandomEntityKey

func (e Entity) NewRandomEntityKey() *EntityKey

type EntityKey

type EntityKey uint64

func NewEntityKey

func NewEntityKey(tokenType, tokenIndex, ctxIndex uint64) *EntityKey

NewEntityKey tokenIndex can not be zero, otherwise it will bo assigned to zero

func NewPublicEntityKey

func NewPublicEntityKey(tokenType TokenType) *EntityKey

NewPublicEntityKey so called publicEntityKey means tokenIndex and ContextIndex is zero PublicEntityKey means app isn't assigned a key, and the key will be randomly sent to an instance for processing

func (*EntityKey) AtoI

func (e *EntityKey) AtoI(s string) *EntityKey

func (EntityKey) ContextIndex

func (e EntityKey) ContextIndex() ContextIndex

func (EntityKey) IsPublicEntityKey

func (e EntityKey) IsPublicEntityKey() bool

func (*EntityKey) ItoA

func (e *EntityKey) ItoA() string

func (EntityKey) MapToTopic

func (e EntityKey) MapToTopic() string

func (*EntityKey) SetContextIndex

func (e *EntityKey) SetContextIndex(ctxIndex ContextIndex) *EntityKey

func (*EntityKey) SetToken

func (e *EntityKey) SetToken(token Token) *EntityKey

func (*EntityKey) SetTokenIndex

func (e *EntityKey) SetTokenIndex(tokenIndex TokenIndex) *EntityKey

func (*EntityKey) SetTokenType

func (e *EntityKey) SetTokenType(tokenType TokenType) *EntityKey

func (EntityKey) Token

func (e EntityKey) Token() Token

func (EntityKey) TokenIndex

func (e EntityKey) TokenIndex() TokenIndex

func (EntityKey) TokenType

func (e EntityKey) TokenType() TokenType

type ReceiveHandler

type ReceiveHandler func(srcKey EntityKey, dstKey EntityKey, msg *message.Message) error

type Token

type Token uint64

type TokenIndex

type TokenIndex uint64

type TokenType

type TokenType uint64