bvllservice

package
v0.0.0-...-f95323f Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 20, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithBIPForeignAddress 

func WithBIPForeignAddress(addr *Address) GenericApplier[*BIPForeign]

func WithBIPForeignTTL 

func WithBIPForeignTTL(ttl uint16) GenericApplier[*BIPForeign]

Types

type AnnexJCodec 

type AnnexJCodec struct {
	ClientContract
	ServerContract
	*DefaultRFormatter `ignore:"true"`
	// contains filtered or unexported fields
}

func NewAnnexJCodec 

func NewAnnexJCodec(localLog zerolog.Logger, options ...Option) (*AnnexJCodec, error)

func (*AnnexJCodec) Confirmation 

func (b *AnnexJCodec) Confirmation(args Args, kwArgs KWArgs) error

func (*AnnexJCodec) Indication 

func (b *AnnexJCodec) Indication(args Args, kwArgs KWArgs) error

func (*AnnexJCodec) Serialize 

func (d *AnnexJCodec) Serialize() ([]byte, error)

func (*AnnexJCodec) SerializeWithWriteBuffer 

func (d *AnnexJCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*AnnexJCodec) String 

func (d *AnnexJCodec) String() string

type BIPBBMD 

type BIPBBMD struct {
	*BIPSAP
	ClientContract
	ServerContract
	*RecurringTask
	*DebugContents `ignore:"true"`
	// contains filtered or unexported fields
}

func NewBIPBBMD 

func NewBIPBBMD(localLog zerolog.Logger, addr *Address, options ...Option) (*BIPBBMD, error)

func (*BIPBBMD) AddPeer 

func (b *BIPBBMD) AddPeer(address Arg) error

func (*BIPBBMD) Confirmation 

func (b *BIPBBMD) Confirmation(args Args, kwArgs KWArgs) error

func (*BIPBBMD) DeleteForeignDeviceTableEntry 

func (b *BIPBBMD) DeleteForeignDeviceTableEntry(address Arg) (model.BVLCResultCode, error)

func (*BIPBBMD) DeletePeer 

func (b *BIPBBMD) DeletePeer(address Arg) error

func (*BIPBBMD) GetDebugAttr 

func (b *BIPBBMD) GetDebugAttr(attr string) any

func (*BIPBBMD) Indication 

func (b *BIPBBMD) Indication(args Args, kwArgs KWArgs) error

func (*BIPBBMD) ProcessTask 

func (b *BIPBBMD) ProcessTask() error

func (*BIPBBMD) RegisterForeignDevice 

func (b *BIPBBMD) RegisterForeignDevice(address Arg, ttl uint16) (model.BVLCResultCode, error)

func (*BIPBBMD) Serialize 

func (d *BIPBBMD) Serialize() ([]byte, error)

func (*BIPBBMD) SerializeWithWriteBuffer 

func (d *BIPBBMD) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*BIPBBMD) String 

func (d *BIPBBMD) String() string

type BIPForeign 

type BIPForeign struct {
	*DebugContents `ignore:"true"`
	*BIPSAP
	ClientContract
	ServerContract
	*OneShotTask
	// contains filtered or unexported fields
}

func NewBIPForeign 

func NewBIPForeign(localLog zerolog.Logger, options ...Option) (*BIPForeign, error)

func (*BIPForeign) Confirmation 

func (b *BIPForeign) Confirmation(args Args, kwArgs KWArgs) error

func (*BIPForeign) GetDebugAttr 

func (b *BIPForeign) GetDebugAttr(attr string) any

func (*BIPForeign) Indication 

func (b *BIPForeign) Indication(args Args, kwArgs KWArgs) error

func (*BIPForeign) ProcessTask 

func (b *BIPForeign) ProcessTask() error

ProcessTask is called when the registration request should be sent to the BBMD.

func (*BIPForeign) Register 

func (b *BIPForeign) Register(addr *Address, ttl uint16) error

Register starts the foreign device registration process with the given BBMD. 

Registration will be renewed periodically according to the ttl value
until explicitly stopped by a call to `unregister`.

func (*BIPForeign) Serialize 

func (d *BIPForeign) Serialize() ([]byte, error)

func (*BIPForeign) SerializeWithWriteBuffer 

func (d *BIPForeign) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*BIPForeign) String 

func (d *BIPForeign) String() string

func (*BIPForeign) Unregister 

func (b *BIPForeign) Unregister()

Unregister stops the foreign device registration process.

Immediately drops active foreign device registration and stops further registration renewals.

type BIPSAP 

type BIPSAP struct {
	ServiceAccessPointContract
	*DefaultRFormatter `ignore:"true"`
	// contains filtered or unexported fields
}

func NewBIPSAP 

func NewBIPSAP(localLog zerolog.Logger, requirements BIPSAPRequirements, options ...Option) (*BIPSAP, error)

func (*BIPSAP) SapConfirmation 

func (b *BIPSAP) SapConfirmation(args Args, kwArgs KWArgs) error

func (*BIPSAP) SapIndication 

func (b *BIPSAP) SapIndication(args Args, kwArgs KWArgs) error

func (*BIPSAP) String 

func (b *BIPSAP) String() string

type BIPSAPRequirements 

type BIPSAPRequirements interface {
	ServiceAccessPoint
	Client
}

type BIPSimple 

type BIPSimple struct {
	*BIPSAP
	ClientContract
	ServerContract
	*debugging.DefaultRFormatter `ignore:"true"`
	// contains filtered or unexported fields
}

func NewBIPSimple 

func NewBIPSimple(localLog zerolog.Logger, options ...Option) (*BIPSimple, error)

func (*BIPSimple) Confirmation 

func (b *BIPSimple) Confirmation(args Args, kwArgs KWArgs) error

func (*BIPSimple) Indication 

func (b *BIPSimple) Indication(args Args, kwArgs KWArgs) error

func (*BIPSimple) Serialize 

func (d *BIPSimple) Serialize() ([]byte, error)

func (*BIPSimple) SerializeWithWriteBuffer 

func (d *BIPSimple) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*BIPSimple) String 

func (d *BIPSimple) String() string

type UDPMultiplexer 

type UDPMultiplexer struct {
	AnnexJ *_MultiplexServer
	// contains filtered or unexported fields
}

func NewUDPMultiplexer 

func NewUDPMultiplexer(localLog zerolog.Logger, address any, noBroadcast bool, options ...Option) (*UDPMultiplexer, error)

func (*UDPMultiplexer) Close 

func (m *UDPMultiplexer) Close() error

func (*UDPMultiplexer) Confirmation 

func (m *UDPMultiplexer) Confirmation(args Args, kwArgs KWArgs) error

func (*UDPMultiplexer) Indication 

func (m *UDPMultiplexer) Indication(args Args, kwArgs KWArgs) error

func (*UDPMultiplexer) Serialize 

func (d *UDPMultiplexer) Serialize() ([]byte, error)

func (*UDPMultiplexer) SerializeWithWriteBuffer 

func (d *UDPMultiplexer) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*UDPMultiplexer) String 

func (d *UDPMultiplexer) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.