driver

Documentation

Index

• Variables
• type Listener
• type ListenerAdapter
  • func NewAdapter(driverListener Listener, broadcastReceiver *broadcast.CopyReceiver) *ListenerAdapter
  • func (adapter *ListenerAdapter) ReceiveMessages() int
• type Proxy
  • func (driver *Proxy) AddExclusivePublication(channel string, streamID int32) int64
  • func (driver *Proxy) AddPublication(channel string, streamID int32) int64
  • func (driver *Proxy) AddSubscription(channel string, streamID int32) int64
  • func (driver *Proxy) ClientID() int64
  • func (driver *Proxy) Init(buffer *rb.ManyToOne) *Proxy
  • func (driver *Proxy) NextCorrelationID() int64
  • func (driver *Proxy) RemovePublication(registrationID int64)
  • func (driver *Proxy) RemoveSubscription(registrationID int64)
  • func (driver *Proxy) SendClientKeepalive()
  • func (driver *Proxy) TimeOfLastDriverKeepalive() int64
• type SubscriberPosition
  • func (pos *SubscriberPosition) IndicatorID() int32
  • func (pos *SubscriberPosition) RegistrationID() int64

Variables

var Events = struct {
	/** Error Response */
	OnError int32
	/** New subscription Buffer Notification */
	OnAvailableImage int32
	/** New publication Buffer Notification */
	OnPublicationReady int32
	/** Operation Succeeded */
	OnOperationSuccess int32
	/** Inform client of timeout and removal of inactive image */
	OnUnavailableImage int32
	/** New Exclusive Publication Buffer notification */
	OnExclusivePublicationReady int32
	/** New subscription notification */
	OnSubscriptionReady int32
	/** New counter notification */
	OnCounterReady int32
	/** inform clients of removal of counter */
	OnUnavailableCounter int32
	/** inform clients of client timeout */
	OnClientTimeout int32
}{
	0x0F01,
	0x0F02,
	0x0F03,
	0x0F04,
	0x0F05,
	0x0F06,
	0x0F07,
	0x0F08,
	0x0F09,
	0x0F0A,
}

Types

type Listener

type Listener interface {
	OnNewPublication(streamID int32, sessionID int32, positionLimitCounterID int32, channelStatusIndicatorID int32,
		logFileName string, correlationID int64, registrationID int64)
	OnNewExclusivePublication(streamID int32, sessionID int32, positionLimitCounterID int32, channelStatusIndicatorID int32,
		logFileName string, correlationID int64, registrationID int64)
	OnAvailableImage(streamID int32, sessionID int32, logFilename string, sourceIdentity string,
		subscriberPositionID int32, subsRegID int64, correlationID int64)
	OnUnavailableImage(correlationID int64, subscriptionRegistrationID int64)
	OnOperationSuccess(correlationID int64)
	OnErrorResponse(offendingCommandCorrelationID int64, errorCode int32, errorMessage string)
	OnSubscriptionReady(correlationID int64, channelStatusIndicatorID int32)
	OnAvailableCounter(correlationID int64, counterID int32)
	OnUnavailableCounter(correlationID int64, counterID int32)
	OnClientTimeout(clientID int64)
}

type ListenerAdapter

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

func NewAdapter

func NewAdapter(driverListener Listener, broadcastReceiver *broadcast.CopyReceiver) *ListenerAdapter

func (*ListenerAdapter) ReceiveMessages

func (adapter *ListenerAdapter) ReceiveMessages() int

type Proxy

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

Proxy is a media driver proxy class that is used to send commands

func (*Proxy) AddExclusivePublication

func (driver *Proxy) AddExclusivePublication(channel string, streamID int32) int64

AddExclusivePublication sends driver command to add new publication

func (*Proxy) AddPublication

func (driver *Proxy) AddPublication(channel string, streamID int32) int64

AddPublication sends driver command to add new publication

func (*Proxy) AddSubscription

func (driver *Proxy) AddSubscription(channel string, streamID int32) int64

AddSubscription sends driver command to add new subscription

func (*Proxy) ClientID

func (driver *Proxy) ClientID() int64

ClientID returns the client ID for this connection to the driver.

func (*Proxy) Init

func (driver *Proxy) Init(buffer *rb.ManyToOne) *Proxy

Init initializes media driver proxy class

func (*Proxy) NextCorrelationID

func (driver *Proxy) NextCorrelationID() int64

NextCorrelationID generates the next correlation id that is unique for the connected Media Driver.

func (*Proxy) RemovePublication

func (driver *Proxy) RemovePublication(registrationID int64)

RemovePublication sends driver command to remove publication

func (*Proxy) RemoveSubscription

func (driver *Proxy) RemoveSubscription(registrationID int64)

RemoveSubscription sends driver command to remove subscription

func (*Proxy) SendClientKeepalive

func (driver *Proxy) SendClientKeepalive()

SendClientKeepalive send keep alive message to the driver

func (*Proxy) TimeOfLastDriverKeepalive

func (driver *Proxy) TimeOfLastDriverKeepalive() int64

TimeOfLastDriverKeepalive gets the time of the last keep alive update sent to media driver

type SubscriberPosition

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

func (*SubscriberPosition) IndicatorID

func (pos *SubscriberPosition) IndicatorID() int32

func (*SubscriberPosition) RegistrationID

func (pos *SubscriberPosition) RegistrationID() int64