codecs

package
v0.0.0-...-f6902ab Latest Latest
Warning

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

 Go to latest Published: Nov 3, 2023 License: Apache-2.0 Imports: 6 Imported by: 2

README

Aeron Codecs

The control protocol for the Java Aeron Archive is a collection of SBE messages.

These generated codecs are added to the repository to reduce the build prerequisites and to better enable configuration management. They were built using generate.sh.

generate.sh should be taken more as a encoded description of what needs to be done as it needs to know the locations of the additional tools of simple-binary-encoding and agrona.

Should the protocol version change you will need to update the semantic version in semanticversion.go

Documentation

Overview

Package codecs contains the archive protocol packet encoding and decoding

Index

Constants

This section is empty.

Variables

View Source 
var BooleanType = BooleanTypeValues{0, 1, -2147483648}
View Source 
var ControlResponseCode = ControlResponseCodeValues{0, 1, 2, 3, -2147483648}
View Source 
var RecordingSignal = RecordingSignalValues{0, 1, 2, 3, 4, 5, 6, -2147483648}
View Source 
var RecordingState = RecordingStateValues{0, 1, -2147483648}
View Source 
var SourceLocation = SourceLocationValues{0, 1, -2147483648}

Functions

func AttachSegmentsRequestInit 

func AttachSegmentsRequestInit(a *AttachSegmentsRequest)

func AttachSegmentsRequestPacket 

func AttachSegmentsRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64) ([]byte, error)

func AuthConnectRequestInit 

func AuthConnectRequestInit(a *AuthConnectRequest)

func AuthConnectRequestPacket 

func AuthConnectRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, correlationID int64, responseStream int32, responseChannel string, encodedCredentials []uint8) ([]byte, error)

func BoundedReplayPacket 

func BoundedReplayPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64, position int64, length int64, limitCounterId int32, replayStream int32, replayChannel string) ([]byte, error)

func BoundedReplayRequestInit 

func BoundedReplayRequestInit(b *BoundedReplayRequest)

func CatalogHeaderInit 

func CatalogHeaderInit(c *CatalogHeader)

func CatalogHeaderPacket 

func CatalogHeaderPacket(marshaller *SbeGoMarshaller, rangeChecking bool, version int32, length int32, nextRecordingId int64, alignment int32) ([]byte, error)

func ChallengeInit 

func ChallengeInit(c *Challenge)

func ChallengeResponseInit 

func ChallengeResponseInit(c *ChallengeResponse)

func ChallengeResponsePacket 

func ChallengeResponsePacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, encodedCredentials []uint8) ([]byte, error)

func CloseSessionRequestInit 

func CloseSessionRequestInit(c *CloseSessionRequest)

func CloseSessionRequestPacket 

func CloseSessionRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64) ([]byte, error)

func ConnectRequestInit 

func ConnectRequestInit(c *ConnectRequest)

func ConnectRequestPacket 

func ConnectRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, correlationID int64, responseStream int32, responseChannel string) ([]byte, error)

Encoders for all the protocol packets

Each of these functions creates a []byte suitable for sending over the wire by using the generated encoders created using simple-binary-encoding.

All the packet specificationss are defined in the aeron-archive protocol maintained at: http://github.com/real-logic/aeron/blob/master/aeron-archive/src/main/resources/archive/aeron-archive-codecs.xml)

The codecs are generated from that specification using Simple Binary Encoding (SBE) from https://github.com/real-logic/simple-binary-encoding

func ControlResponseInit 

func ControlResponseInit(c *ControlResponse)

func DeleteDetachedSegmentsRequestInit 

func DeleteDetachedSegmentsRequestInit(d *DeleteDetachedSegmentsRequest)

func DeleteDetachedSegmentsRequestPacket 

func DeleteDetachedSegmentsRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64) ([]byte, error)

func DetachSegmentsRequestInit 

func DetachSegmentsRequestInit(d *DetachSegmentsRequest)

func DetachSegmentsRequestPacket 

func DetachSegmentsRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64, newStartPosition int64) ([]byte, error)

func ExtendRecordingRequest2Init 

func ExtendRecordingRequest2Init(e *ExtendRecordingRequest2)

func ExtendRecordingRequest2Packet 

func ExtendRecordingRequest2Packet(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64, stream int32, sourceLocation SourceLocationEnum, autoStop bool, channel string) ([]byte, error)

func ExtendRecordingRequestInit 

func ExtendRecordingRequestInit(e *ExtendRecordingRequest)

func ExtendRecordingRequestPacket 

func ExtendRecordingRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64, stream int32, sourceLocation SourceLocationEnum, channel string) ([]byte, error)

deprecated

func FindLastMatchingRecordingPacket 

func FindLastMatchingRecordingPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, minRecordingId int64, sessionId int32, stream int32, channel string) ([]byte, error)

func FindLastMatchingRecordingRequestInit 

func FindLastMatchingRecordingRequestInit(f *FindLastMatchingRecordingRequest)

func KeepAliveRequestInit 

func KeepAliveRequestInit(k *KeepAliveRequest)

func KeepAliveRequestPacket 

func KeepAliveRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64) ([]byte, error)

func ListRecordingRequestInit 

func ListRecordingRequestInit(l *ListRecordingRequest)

func ListRecordingRequestPacket 

func ListRecordingRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64) ([]byte, error)

func ListRecordingSubscriptionsPacket 

func ListRecordingSubscriptionsPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, pseudoIndex int32, subscriptionCount int32, applyStreamId bool, stream int32, channel string) ([]byte, error)

func ListRecordingSubscriptionsRequestInit 

func ListRecordingSubscriptionsRequestInit(l *ListRecordingSubscriptionsRequest)

func ListRecordingsForUriRequestInit 

func ListRecordingsForUriRequestInit(l *ListRecordingsForUriRequest)

func ListRecordingsForUriRequestPacket 

func ListRecordingsForUriRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, fromRecordingId int64, recordCount int32, stream int32, channel string) ([]byte, error)

func ListRecordingsRequestInit 

func ListRecordingsRequestInit(l *ListRecordingsRequest)

func ListRecordingsRequestPacket 

func ListRecordingsRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, fromRecordingId int64, recordCount int32) ([]byte, error)

func MessageHeaderInit 

func MessageHeaderInit(m *MessageHeader)

func MigrateSegmentsRequestInit 

func MigrateSegmentsRequestInit(m *MigrateSegmentsRequest)

func MigrateSegmentsRequestPacket 

func MigrateSegmentsRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, srcRecordingId int64, destRecordingId int64) ([]byte, error)

func PurgeRecordingRequestInit 

func PurgeRecordingRequestInit(p *PurgeRecordingRequest)

func PurgeRecordingRequestPacket 

func PurgeRecordingRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64) ([]byte, error)

func PurgeSegmentsRequestInit 

func PurgeSegmentsRequestInit(p *PurgeSegmentsRequest)

func PurgeSegmentsRequestPacket 

func PurgeSegmentsRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64, newStartPosition int64) ([]byte, error)

func RecordingDescriptorHeaderInit 

func RecordingDescriptorHeaderInit(r *RecordingDescriptorHeader)

func RecordingDescriptorInit 

func RecordingDescriptorInit(r *RecordingDescriptor)

func RecordingPositionRequestInit 

func RecordingPositionRequestInit(r *RecordingPositionRequest)

func RecordingPositionRequestPacket 

func RecordingPositionRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64) ([]byte, error)

func RecordingProgressInit 

func RecordingProgressInit(r *RecordingProgress)

func RecordingSignalEventInit 

func RecordingSignalEventInit(r *RecordingSignalEvent)

func RecordingStartedInit 

func RecordingStartedInit(r *RecordingStarted)

func RecordingStoppedInit 

func RecordingStoppedInit(r *RecordingStopped)

func RecordingSubscriptionDescriptorInit 

func RecordingSubscriptionDescriptorInit(r *RecordingSubscriptionDescriptor)

func ReplayRequestInit 

func ReplayRequestInit(r *ReplayRequest)

func ReplayRequestPacket 

func ReplayRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64, position int64, length int64, replayStream int32, replayChannel string) ([]byte, error)

func ReplicateRequest2Init 

func ReplicateRequest2Init(r *ReplicateRequest2)

func ReplicateRequest2Packet 

func ReplicateRequest2Packet(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, srcRecordingId int64, dstRecordingId int64, stopPosition int64, channelTagId int64, srcControlStreamId int32, srcControlChannel string, liveDestination string, replicationChannel string) ([]byte, error)

func ReplicateRequestInit 

func ReplicateRequestInit(r *ReplicateRequest)

func ReplicateRequestPacket 

func ReplicateRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, srcRecordingId int64, dstRecordingId int64, srcControlStreamId int32, srcControlChannel string, liveDestination string) ([]byte, error)

func SemanticVersion 

func SemanticVersion() int32

func StartPositionRequestInit 

func StartPositionRequestInit(s *StartPositionRequest)

func StartPositionRequestPacket 

func StartPositionRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64) ([]byte, error)

func StartRecordingRequest2Init 

func StartRecordingRequest2Init(s *StartRecordingRequest2)

func StartRecordingRequest2Packet 

func StartRecordingRequest2Packet(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, stream int32, isLocal bool, autoStop bool, channel string) ([]byte, error)

func StartRecordingRequestInit 

func StartRecordingRequestInit(s *StartRecordingRequest)

func StartRecordingRequestPacket 

func StartRecordingRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, stream int32, isLocal bool, channel string) ([]byte, error)

deprecated

func StopAllReplaysPacket 

func StopAllReplaysPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64) ([]byte, error)

func StopAllReplaysRequestInit 

func StopAllReplaysRequestInit(s *StopAllReplaysRequest)

func StopPositionPacket 

func StopPositionPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64) ([]byte, error)

func StopPositionRequestInit 

func StopPositionRequestInit(s *StopPositionRequest)

func StopRecordingByIdentityPacket 

func StopRecordingByIdentityPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64) ([]byte, error)

func StopRecordingByIdentityRequestInit 

func StopRecordingByIdentityRequestInit(s *StopRecordingByIdentityRequest)

func StopRecordingRequestInit 

func StopRecordingRequestInit(s *StopRecordingRequest)

func StopRecordingRequestPacket 

func StopRecordingRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, stream int32, channel string) ([]byte, error)

func StopRecordingSubscriptionPacket 

func StopRecordingSubscriptionPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, subscriptionId int64) ([]byte, error)

func StopRecordingSubscriptionRequestInit 

func StopRecordingSubscriptionRequestInit(s *StopRecordingSubscriptionRequest)

func StopReplayRequestInit 

func StopReplayRequestInit(s *StopReplayRequest)

func StopReplayRequestPacket 

func StopReplayRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, replaySessionId int64) ([]byte, error)

func StopReplicationRequestInit 

func StopReplicationRequestInit(s *StopReplicationRequest)

func StopReplicationRequestPacket 

func StopReplicationRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, replicationId int64) ([]byte, error)

func TaggedReplicateRequestInit 

func TaggedReplicateRequestInit(t *TaggedReplicateRequest)

func TaggedReplicateRequestPacket 

func TaggedReplicateRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, srcRecordingId int64, dstRecordingId int64, channelTagId int64, subscriptionTagId int64, srcControlStreamId int32, srcControlChannel string, liveDestination string) ([]byte, error)

func TruncateRecordingRequestInit 

func TruncateRecordingRequestInit(t *TruncateRecordingRequest)

func TruncateRecordingRequestPacket 

func TruncateRecordingRequestPacket(marshaller *SbeGoMarshaller, rangeChecking bool, controlSessionId int64, correlationId int64, recordingId int64, position int64) ([]byte, error)

func VarAsciiEncodingInit 

func VarAsciiEncodingInit(v *VarAsciiEncoding)

func VarDataEncodingInit 

func VarDataEncodingInit(v *VarDataEncoding)

Types

type AttachSegmentsRequest 

type AttachSegmentsRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
}

func (*AttachSegmentsRequest) ControlSessionIdDeprecated 

func (*AttachSegmentsRequest) ControlSessionIdDeprecated() uint16

func (*AttachSegmentsRequest) ControlSessionIdId 

func (*AttachSegmentsRequest) ControlSessionIdId() uint16

func (*AttachSegmentsRequest) ControlSessionIdInActingVersion 

func (a *AttachSegmentsRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*AttachSegmentsRequest) ControlSessionIdMaxValue 

func (*AttachSegmentsRequest) ControlSessionIdMaxValue() int64

func (*AttachSegmentsRequest) ControlSessionIdMetaAttribute 

func (*AttachSegmentsRequest) ControlSessionIdMetaAttribute(meta int) string

func (*AttachSegmentsRequest) ControlSessionIdMinValue 

func (*AttachSegmentsRequest) ControlSessionIdMinValue() int64

func (*AttachSegmentsRequest) ControlSessionIdNullValue 

func (*AttachSegmentsRequest) ControlSessionIdNullValue() int64

func (*AttachSegmentsRequest) ControlSessionIdSinceVersion 

func (*AttachSegmentsRequest) ControlSessionIdSinceVersion() uint16

func (*AttachSegmentsRequest) CorrelationIdDeprecated 

func (*AttachSegmentsRequest) CorrelationIdDeprecated() uint16

func (*AttachSegmentsRequest) CorrelationIdId 

func (*AttachSegmentsRequest) CorrelationIdId() uint16

func (*AttachSegmentsRequest) CorrelationIdInActingVersion 

func (a *AttachSegmentsRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*AttachSegmentsRequest) CorrelationIdMaxValue 

func (*AttachSegmentsRequest) CorrelationIdMaxValue() int64

func (*AttachSegmentsRequest) CorrelationIdMetaAttribute 

func (*AttachSegmentsRequest) CorrelationIdMetaAttribute(meta int) string

func (*AttachSegmentsRequest) CorrelationIdMinValue 

func (*AttachSegmentsRequest) CorrelationIdMinValue() int64

func (*AttachSegmentsRequest) CorrelationIdNullValue 

func (*AttachSegmentsRequest) CorrelationIdNullValue() int64

func (*AttachSegmentsRequest) CorrelationIdSinceVersion 

func (*AttachSegmentsRequest) CorrelationIdSinceVersion() uint16

func (*AttachSegmentsRequest) Decode 

func (a *AttachSegmentsRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*AttachSegmentsRequest) Encode 

func (a *AttachSegmentsRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*AttachSegmentsRequest) RangeCheck 

func (a *AttachSegmentsRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*AttachSegmentsRequest) RecordingIdDeprecated 

func (*AttachSegmentsRequest) RecordingIdDeprecated() uint16

func (*AttachSegmentsRequest) RecordingIdId 

func (*AttachSegmentsRequest) RecordingIdId() uint16

func (*AttachSegmentsRequest) RecordingIdInActingVersion 

func (a *AttachSegmentsRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*AttachSegmentsRequest) RecordingIdMaxValue 

func (*AttachSegmentsRequest) RecordingIdMaxValue() int64

func (*AttachSegmentsRequest) RecordingIdMetaAttribute 

func (*AttachSegmentsRequest) RecordingIdMetaAttribute(meta int) string

func (*AttachSegmentsRequest) RecordingIdMinValue 

func (*AttachSegmentsRequest) RecordingIdMinValue() int64

func (*AttachSegmentsRequest) RecordingIdNullValue 

func (*AttachSegmentsRequest) RecordingIdNullValue() int64

func (*AttachSegmentsRequest) RecordingIdSinceVersion 

func (*AttachSegmentsRequest) RecordingIdSinceVersion() uint16

func (*AttachSegmentsRequest) SbeBlockLength 

func (*AttachSegmentsRequest) SbeBlockLength() (blockLength uint16)

func (*AttachSegmentsRequest) SbeSchemaId 

func (*AttachSegmentsRequest) SbeSchemaId() (schemaId uint16)

func (*AttachSegmentsRequest) SbeSchemaVersion 

func (*AttachSegmentsRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*AttachSegmentsRequest) SbeSemanticType 

func (*AttachSegmentsRequest) SbeSemanticType() (semanticType []byte)

func (*AttachSegmentsRequest) SbeTemplateId 

func (*AttachSegmentsRequest) SbeTemplateId() (templateId uint16)

type AuthConnectRequest 

type AuthConnectRequest struct {
	CorrelationId      int64
	ResponseStreamId   int32
	Version            int32
	ResponseChannel    []uint8
	EncodedCredentials []uint8
}

func (*AuthConnectRequest) CorrelationIdDeprecated 

func (*AuthConnectRequest) CorrelationIdDeprecated() uint16

func (*AuthConnectRequest) CorrelationIdId 

func (*AuthConnectRequest) CorrelationIdId() uint16

func (*AuthConnectRequest) CorrelationIdInActingVersion 

func (a *AuthConnectRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*AuthConnectRequest) CorrelationIdMaxValue 

func (*AuthConnectRequest) CorrelationIdMaxValue() int64

func (*AuthConnectRequest) CorrelationIdMetaAttribute 

func (*AuthConnectRequest) CorrelationIdMetaAttribute(meta int) string

func (*AuthConnectRequest) CorrelationIdMinValue 

func (*AuthConnectRequest) CorrelationIdMinValue() int64

func (*AuthConnectRequest) CorrelationIdNullValue 

func (*AuthConnectRequest) CorrelationIdNullValue() int64

func (*AuthConnectRequest) CorrelationIdSinceVersion 

func (*AuthConnectRequest) CorrelationIdSinceVersion() uint16

func (*AuthConnectRequest) Decode 

func (a *AuthConnectRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*AuthConnectRequest) Encode 

func (a *AuthConnectRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (AuthConnectRequest) EncodedCredentialsCharacterEncoding 

func (AuthConnectRequest) EncodedCredentialsCharacterEncoding() string

func (*AuthConnectRequest) EncodedCredentialsDeprecated 

func (*AuthConnectRequest) EncodedCredentialsDeprecated() uint16

func (AuthConnectRequest) EncodedCredentialsHeaderLength 

func (AuthConnectRequest) EncodedCredentialsHeaderLength() uint64

func (*AuthConnectRequest) EncodedCredentialsInActingVersion 

func (a *AuthConnectRequest) EncodedCredentialsInActingVersion(actingVersion uint16) bool

func (*AuthConnectRequest) EncodedCredentialsMetaAttribute 

func (*AuthConnectRequest) EncodedCredentialsMetaAttribute(meta int) string

func (*AuthConnectRequest) EncodedCredentialsSinceVersion 

func (*AuthConnectRequest) EncodedCredentialsSinceVersion() uint16

func (*AuthConnectRequest) RangeCheck 

func (a *AuthConnectRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (AuthConnectRequest) ResponseChannelCharacterEncoding 

func (AuthConnectRequest) ResponseChannelCharacterEncoding() string

func (*AuthConnectRequest) ResponseChannelDeprecated 

func (*AuthConnectRequest) ResponseChannelDeprecated() uint16

func (AuthConnectRequest) ResponseChannelHeaderLength 

func (AuthConnectRequest) ResponseChannelHeaderLength() uint64

func (*AuthConnectRequest) ResponseChannelInActingVersion 

func (a *AuthConnectRequest) ResponseChannelInActingVersion(actingVersion uint16) bool

func (*AuthConnectRequest) ResponseChannelMetaAttribute 

func (*AuthConnectRequest) ResponseChannelMetaAttribute(meta int) string

func (*AuthConnectRequest) ResponseChannelSinceVersion 

func (*AuthConnectRequest) ResponseChannelSinceVersion() uint16

func (*AuthConnectRequest) ResponseStreamIdDeprecated 

func (*AuthConnectRequest) ResponseStreamIdDeprecated() uint16

func (*AuthConnectRequest) ResponseStreamIdId 

func (*AuthConnectRequest) ResponseStreamIdId() uint16

func (*AuthConnectRequest) ResponseStreamIdInActingVersion 

func (a *AuthConnectRequest) ResponseStreamIdInActingVersion(actingVersion uint16) bool

func (*AuthConnectRequest) ResponseStreamIdMaxValue 

func (*AuthConnectRequest) ResponseStreamIdMaxValue() int32

func (*AuthConnectRequest) ResponseStreamIdMetaAttribute 

func (*AuthConnectRequest) ResponseStreamIdMetaAttribute(meta int) string

func (*AuthConnectRequest) ResponseStreamIdMinValue 

func (*AuthConnectRequest) ResponseStreamIdMinValue() int32

func (*AuthConnectRequest) ResponseStreamIdNullValue 

func (*AuthConnectRequest) ResponseStreamIdNullValue() int32

func (*AuthConnectRequest) ResponseStreamIdSinceVersion 

func (*AuthConnectRequest) ResponseStreamIdSinceVersion() uint16

func (*AuthConnectRequest) SbeBlockLength 

func (*AuthConnectRequest) SbeBlockLength() (blockLength uint16)

func (*AuthConnectRequest) SbeSchemaId 

func (*AuthConnectRequest) SbeSchemaId() (schemaId uint16)

func (*AuthConnectRequest) SbeSchemaVersion 

func (*AuthConnectRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*AuthConnectRequest) SbeSemanticType 

func (*AuthConnectRequest) SbeSemanticType() (semanticType []byte)

func (*AuthConnectRequest) SbeTemplateId 

func (*AuthConnectRequest) SbeTemplateId() (templateId uint16)

func (*AuthConnectRequest) VersionDeprecated 

func (*AuthConnectRequest) VersionDeprecated() uint16

func (*AuthConnectRequest) VersionId 

func (*AuthConnectRequest) VersionId() uint16

func (*AuthConnectRequest) VersionInActingVersion 

func (a *AuthConnectRequest) VersionInActingVersion(actingVersion uint16) bool

func (*AuthConnectRequest) VersionMaxValue 

func (*AuthConnectRequest) VersionMaxValue() int32

func (*AuthConnectRequest) VersionMetaAttribute 

func (*AuthConnectRequest) VersionMetaAttribute(meta int) string

func (*AuthConnectRequest) VersionMinValue 

func (*AuthConnectRequest) VersionMinValue() int32

func (*AuthConnectRequest) VersionNullValue 

func (*AuthConnectRequest) VersionNullValue() int32

func (*AuthConnectRequest) VersionSinceVersion 

func (*AuthConnectRequest) VersionSinceVersion() uint16

type BooleanTypeEnum 

type BooleanTypeEnum int32

func (*BooleanTypeEnum) Decode 

func (b *BooleanTypeEnum) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16) error

func (BooleanTypeEnum) Encode 

func (b BooleanTypeEnum) Encode(_m *SbeGoMarshaller, _w io.Writer) error

func (*BooleanTypeEnum) EncodedLength 

func (*BooleanTypeEnum) EncodedLength() int64

func (*BooleanTypeEnum) FALSEDeprecated 

func (*BooleanTypeEnum) FALSEDeprecated() uint16

func (*BooleanTypeEnum) FALSEInActingVersion 

func (b *BooleanTypeEnum) FALSEInActingVersion(actingVersion uint16) bool

func (*BooleanTypeEnum) FALSESinceVersion 

func (*BooleanTypeEnum) FALSESinceVersion() uint16

func (BooleanTypeEnum) RangeCheck 

func (b BooleanTypeEnum) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*BooleanTypeEnum) TRUEDeprecated 

func (*BooleanTypeEnum) TRUEDeprecated() uint16

func (*BooleanTypeEnum) TRUEInActingVersion 

func (b *BooleanTypeEnum) TRUEInActingVersion(actingVersion uint16) bool

func (*BooleanTypeEnum) TRUESinceVersion 

func (*BooleanTypeEnum) TRUESinceVersion() uint16

type BooleanTypeValues 

type BooleanTypeValues struct {
	FALSE     BooleanTypeEnum
	TRUE      BooleanTypeEnum
	NullValue BooleanTypeEnum
}

type BoundedReplayRequest 

type BoundedReplayRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
	Position         int64
	Length           int64
	LimitCounterId   int32
	ReplayStreamId   int32
	ReplayChannel    []uint8
}

func (*BoundedReplayRequest) ControlSessionIdDeprecated 

func (*BoundedReplayRequest) ControlSessionIdDeprecated() uint16

func (*BoundedReplayRequest) ControlSessionIdId 

func (*BoundedReplayRequest) ControlSessionIdId() uint16

func (*BoundedReplayRequest) ControlSessionIdInActingVersion 

func (b *BoundedReplayRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*BoundedReplayRequest) ControlSessionIdMaxValue 

func (*BoundedReplayRequest) ControlSessionIdMaxValue() int64

func (*BoundedReplayRequest) ControlSessionIdMetaAttribute 

func (*BoundedReplayRequest) ControlSessionIdMetaAttribute(meta int) string

func (*BoundedReplayRequest) ControlSessionIdMinValue 

func (*BoundedReplayRequest) ControlSessionIdMinValue() int64

func (*BoundedReplayRequest) ControlSessionIdNullValue 

func (*BoundedReplayRequest) ControlSessionIdNullValue() int64

func (*BoundedReplayRequest) ControlSessionIdSinceVersion 

func (*BoundedReplayRequest) ControlSessionIdSinceVersion() uint16

func (*BoundedReplayRequest) CorrelationIdDeprecated 

func (*BoundedReplayRequest) CorrelationIdDeprecated() uint16

func (*BoundedReplayRequest) CorrelationIdId 

func (*BoundedReplayRequest) CorrelationIdId() uint16

func (*BoundedReplayRequest) CorrelationIdInActingVersion 

func (b *BoundedReplayRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*BoundedReplayRequest) CorrelationIdMaxValue 

func (*BoundedReplayRequest) CorrelationIdMaxValue() int64

func (*BoundedReplayRequest) CorrelationIdMetaAttribute 

func (*BoundedReplayRequest) CorrelationIdMetaAttribute(meta int) string

func (*BoundedReplayRequest) CorrelationIdMinValue 

func (*BoundedReplayRequest) CorrelationIdMinValue() int64

func (*BoundedReplayRequest) CorrelationIdNullValue 

func (*BoundedReplayRequest) CorrelationIdNullValue() int64

func (*BoundedReplayRequest) CorrelationIdSinceVersion 

func (*BoundedReplayRequest) CorrelationIdSinceVersion() uint16

func (*BoundedReplayRequest) Decode 

func (b *BoundedReplayRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*BoundedReplayRequest) Encode 

func (b *BoundedReplayRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*BoundedReplayRequest) LengthDeprecated 

func (*BoundedReplayRequest) LengthDeprecated() uint16

func (*BoundedReplayRequest) LengthId 

func (*BoundedReplayRequest) LengthId() uint16

func (*BoundedReplayRequest) LengthInActingVersion 

func (b *BoundedReplayRequest) LengthInActingVersion(actingVersion uint16) bool

func (*BoundedReplayRequest) LengthMaxValue 

func (*BoundedReplayRequest) LengthMaxValue() int64

func (*BoundedReplayRequest) LengthMetaAttribute 

func (*BoundedReplayRequest) LengthMetaAttribute(meta int) string

func (*BoundedReplayRequest) LengthMinValue 

func (*BoundedReplayRequest) LengthMinValue() int64

func (*BoundedReplayRequest) LengthNullValue 

func (*BoundedReplayRequest) LengthNullValue() int64

func (*BoundedReplayRequest) LengthSinceVersion 

func (*BoundedReplayRequest) LengthSinceVersion() uint16

func (*BoundedReplayRequest) LimitCounterIdDeprecated 

func (*BoundedReplayRequest) LimitCounterIdDeprecated() uint16

func (*BoundedReplayRequest) LimitCounterIdId 

func (*BoundedReplayRequest) LimitCounterIdId() uint16

func (*BoundedReplayRequest) LimitCounterIdInActingVersion 

func (b *BoundedReplayRequest) LimitCounterIdInActingVersion(actingVersion uint16) bool

func (*BoundedReplayRequest) LimitCounterIdMaxValue 

func (*BoundedReplayRequest) LimitCounterIdMaxValue() int32

func (*BoundedReplayRequest) LimitCounterIdMetaAttribute 

func (*BoundedReplayRequest) LimitCounterIdMetaAttribute(meta int) string

func (*BoundedReplayRequest) LimitCounterIdMinValue 

func (*BoundedReplayRequest) LimitCounterIdMinValue() int32

func (*BoundedReplayRequest) LimitCounterIdNullValue 

func (*BoundedReplayRequest) LimitCounterIdNullValue() int32

func (*BoundedReplayRequest) LimitCounterIdSinceVersion 

func (*BoundedReplayRequest) LimitCounterIdSinceVersion() uint16

func (*BoundedReplayRequest) PositionDeprecated 

func (*BoundedReplayRequest) PositionDeprecated() uint16

func (*BoundedReplayRequest) PositionId 

func (*BoundedReplayRequest) PositionId() uint16

func (*BoundedReplayRequest) PositionInActingVersion 

func (b *BoundedReplayRequest) PositionInActingVersion(actingVersion uint16) bool

func (*BoundedReplayRequest) PositionMaxValue 

func (*BoundedReplayRequest) PositionMaxValue() int64

func (*BoundedReplayRequest) PositionMetaAttribute 

func (*BoundedReplayRequest) PositionMetaAttribute(meta int) string

func (*BoundedReplayRequest) PositionMinValue 

func (*BoundedReplayRequest) PositionMinValue() int64

func (*BoundedReplayRequest) PositionNullValue 

func (*BoundedReplayRequest) PositionNullValue() int64

func (*BoundedReplayRequest) PositionSinceVersion 

func (*BoundedReplayRequest) PositionSinceVersion() uint16

func (*BoundedReplayRequest) RangeCheck 

func (b *BoundedReplayRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*BoundedReplayRequest) RecordingIdDeprecated 

func (*BoundedReplayRequest) RecordingIdDeprecated() uint16

func (*BoundedReplayRequest) RecordingIdId 

func (*BoundedReplayRequest) RecordingIdId() uint16

func (*BoundedReplayRequest) RecordingIdInActingVersion 

func (b *BoundedReplayRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*BoundedReplayRequest) RecordingIdMaxValue 

func (*BoundedReplayRequest) RecordingIdMaxValue() int64

func (*BoundedReplayRequest) RecordingIdMetaAttribute 

func (*BoundedReplayRequest) RecordingIdMetaAttribute(meta int) string

func (*BoundedReplayRequest) RecordingIdMinValue 

func (*BoundedReplayRequest) RecordingIdMinValue() int64

func (*BoundedReplayRequest) RecordingIdNullValue 

func (*BoundedReplayRequest) RecordingIdNullValue() int64

func (*BoundedReplayRequest) RecordingIdSinceVersion 

func (*BoundedReplayRequest) RecordingIdSinceVersion() uint16

func (BoundedReplayRequest) ReplayChannelCharacterEncoding 

func (BoundedReplayRequest) ReplayChannelCharacterEncoding() string

func (*BoundedReplayRequest) ReplayChannelDeprecated 

func (*BoundedReplayRequest) ReplayChannelDeprecated() uint16

func (BoundedReplayRequest) ReplayChannelHeaderLength 

func (BoundedReplayRequest) ReplayChannelHeaderLength() uint64

func (*BoundedReplayRequest) ReplayChannelInActingVersion 

func (b *BoundedReplayRequest) ReplayChannelInActingVersion(actingVersion uint16) bool

func (*BoundedReplayRequest) ReplayChannelMetaAttribute 

func (*BoundedReplayRequest) ReplayChannelMetaAttribute(meta int) string

func (*BoundedReplayRequest) ReplayChannelSinceVersion 

func (*BoundedReplayRequest) ReplayChannelSinceVersion() uint16

func (*BoundedReplayRequest) ReplayStreamIdDeprecated 

func (*BoundedReplayRequest) ReplayStreamIdDeprecated() uint16

func (*BoundedReplayRequest) ReplayStreamIdId 

func (*BoundedReplayRequest) ReplayStreamIdId() uint16

func (*BoundedReplayRequest) ReplayStreamIdInActingVersion 

func (b *BoundedReplayRequest) ReplayStreamIdInActingVersion(actingVersion uint16) bool

func (*BoundedReplayRequest) ReplayStreamIdMaxValue 

func (*BoundedReplayRequest) ReplayStreamIdMaxValue() int32

func (*BoundedReplayRequest) ReplayStreamIdMetaAttribute 

func (*BoundedReplayRequest) ReplayStreamIdMetaAttribute(meta int) string

func (*BoundedReplayRequest) ReplayStreamIdMinValue 

func (*BoundedReplayRequest) ReplayStreamIdMinValue() int32

func (*BoundedReplayRequest) ReplayStreamIdNullValue 

func (*BoundedReplayRequest) ReplayStreamIdNullValue() int32

func (*BoundedReplayRequest) ReplayStreamIdSinceVersion 

func (*BoundedReplayRequest) ReplayStreamIdSinceVersion() uint16

func (*BoundedReplayRequest) SbeBlockLength 

func (*BoundedReplayRequest) SbeBlockLength() (blockLength uint16)

func (*BoundedReplayRequest) SbeSchemaId 

func (*BoundedReplayRequest) SbeSchemaId() (schemaId uint16)

func (*BoundedReplayRequest) SbeSchemaVersion 

func (*BoundedReplayRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*BoundedReplayRequest) SbeSemanticType 

func (*BoundedReplayRequest) SbeSemanticType() (semanticType []byte)

func (*BoundedReplayRequest) SbeTemplateId 

func (*BoundedReplayRequest) SbeTemplateId() (templateId uint16)

type CatalogHeader 

type CatalogHeader struct {
	Version         int32
	Length          int32
	NextRecordingId int64
	Alignment       int32
	Reserved        int8
}

func (*CatalogHeader) AlignmentDeprecated 

func (*CatalogHeader) AlignmentDeprecated() uint16

func (*CatalogHeader) AlignmentId 

func (*CatalogHeader) AlignmentId() uint16

func (*CatalogHeader) AlignmentInActingVersion 

func (c *CatalogHeader) AlignmentInActingVersion(actingVersion uint16) bool

func (*CatalogHeader) AlignmentMaxValue 

func (*CatalogHeader) AlignmentMaxValue() int32

func (*CatalogHeader) AlignmentMetaAttribute 

func (*CatalogHeader) AlignmentMetaAttribute(meta int) string

func (*CatalogHeader) AlignmentMinValue 

func (*CatalogHeader) AlignmentMinValue() int32

func (*CatalogHeader) AlignmentNullValue 

func (*CatalogHeader) AlignmentNullValue() int32

func (*CatalogHeader) AlignmentSinceVersion 

func (*CatalogHeader) AlignmentSinceVersion() uint16

func (*CatalogHeader) Decode 

func (c *CatalogHeader) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*CatalogHeader) Encode 

func (c *CatalogHeader) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*CatalogHeader) LengthDeprecated 

func (*CatalogHeader) LengthDeprecated() uint16

func (*CatalogHeader) LengthId 

func (*CatalogHeader) LengthId() uint16

func (*CatalogHeader) LengthInActingVersion 

func (c *CatalogHeader) LengthInActingVersion(actingVersion uint16) bool

func (*CatalogHeader) LengthMaxValue 

func (*CatalogHeader) LengthMaxValue() int32

func (*CatalogHeader) LengthMetaAttribute 

func (*CatalogHeader) LengthMetaAttribute(meta int) string

func (*CatalogHeader) LengthMinValue 

func (*CatalogHeader) LengthMinValue() int32

func (*CatalogHeader) LengthNullValue 

func (*CatalogHeader) LengthNullValue() int32

func (*CatalogHeader) LengthSinceVersion 

func (*CatalogHeader) LengthSinceVersion() uint16

func (*CatalogHeader) NextRecordingIdDeprecated 

func (*CatalogHeader) NextRecordingIdDeprecated() uint16

func (*CatalogHeader) NextRecordingIdId 

func (*CatalogHeader) NextRecordingIdId() uint16

func (*CatalogHeader) NextRecordingIdInActingVersion 

func (c *CatalogHeader) NextRecordingIdInActingVersion(actingVersion uint16) bool

func (*CatalogHeader) NextRecordingIdMaxValue 

func (*CatalogHeader) NextRecordingIdMaxValue() int64

func (*CatalogHeader) NextRecordingIdMetaAttribute 

func (*CatalogHeader) NextRecordingIdMetaAttribute(meta int) string

func (*CatalogHeader) NextRecordingIdMinValue 

func (*CatalogHeader) NextRecordingIdMinValue() int64

func (*CatalogHeader) NextRecordingIdNullValue 

func (*CatalogHeader) NextRecordingIdNullValue() int64

func (*CatalogHeader) NextRecordingIdSinceVersion 

func (*CatalogHeader) NextRecordingIdSinceVersion() uint16

func (*CatalogHeader) RangeCheck 

func (c *CatalogHeader) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*CatalogHeader) ReservedDeprecated 

func (*CatalogHeader) ReservedDeprecated() uint16

func (*CatalogHeader) ReservedId 

func (*CatalogHeader) ReservedId() uint16

func (*CatalogHeader) ReservedInActingVersion 

func (c *CatalogHeader) ReservedInActingVersion(actingVersion uint16) bool

func (*CatalogHeader) ReservedMaxValue 

func (*CatalogHeader) ReservedMaxValue() int8

func (*CatalogHeader) ReservedMetaAttribute 

func (*CatalogHeader) ReservedMetaAttribute(meta int) string

func (*CatalogHeader) ReservedMinValue 

func (*CatalogHeader) ReservedMinValue() int8

func (*CatalogHeader) ReservedNullValue 

func (*CatalogHeader) ReservedNullValue() int8

func (*CatalogHeader) ReservedSinceVersion 

func (*CatalogHeader) ReservedSinceVersion() uint16

func (*CatalogHeader) SbeBlockLength 

func (*CatalogHeader) SbeBlockLength() (blockLength uint16)

func (*CatalogHeader) SbeSchemaId 

func (*CatalogHeader) SbeSchemaId() (schemaId uint16)

func (*CatalogHeader) SbeSchemaVersion 

func (*CatalogHeader) SbeSchemaVersion() (schemaVersion uint16)

func (*CatalogHeader) SbeSemanticType 

func (*CatalogHeader) SbeSemanticType() (semanticType []byte)

func (*CatalogHeader) SbeTemplateId 

func (*CatalogHeader) SbeTemplateId() (templateId uint16)

func (*CatalogHeader) VersionDeprecated 

func (*CatalogHeader) VersionDeprecated() uint16

func (*CatalogHeader) VersionId 

func (*CatalogHeader) VersionId() uint16

func (*CatalogHeader) VersionInActingVersion 

func (c *CatalogHeader) VersionInActingVersion(actingVersion uint16) bool

func (*CatalogHeader) VersionMaxValue 

func (*CatalogHeader) VersionMaxValue() int32

func (*CatalogHeader) VersionMetaAttribute 

func (*CatalogHeader) VersionMetaAttribute(meta int) string

func (*CatalogHeader) VersionMinValue 

func (*CatalogHeader) VersionMinValue() int32

func (*CatalogHeader) VersionNullValue 

func (*CatalogHeader) VersionNullValue() int32

func (*CatalogHeader) VersionSinceVersion 

func (*CatalogHeader) VersionSinceVersion() uint16

type Challenge 

type Challenge struct {
	ControlSessionId int64
	CorrelationId    int64
	Version          int32
	EncodedChallenge []uint8
}

func (*Challenge) ControlSessionIdDeprecated 

func (*Challenge) ControlSessionIdDeprecated() uint16

func (*Challenge) ControlSessionIdId 

func (*Challenge) ControlSessionIdId() uint16

func (*Challenge) ControlSessionIdInActingVersion 

func (c *Challenge) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*Challenge) ControlSessionIdMaxValue 

func (*Challenge) ControlSessionIdMaxValue() int64

func (*Challenge) ControlSessionIdMetaAttribute 

func (*Challenge) ControlSessionIdMetaAttribute(meta int) string

func (*Challenge) ControlSessionIdMinValue 

func (*Challenge) ControlSessionIdMinValue() int64

func (*Challenge) ControlSessionIdNullValue 

func (*Challenge) ControlSessionIdNullValue() int64

func (*Challenge) ControlSessionIdSinceVersion 

func (*Challenge) ControlSessionIdSinceVersion() uint16

func (*Challenge) CorrelationIdDeprecated 

func (*Challenge) CorrelationIdDeprecated() uint16

func (*Challenge) CorrelationIdId 

func (*Challenge) CorrelationIdId() uint16

func (*Challenge) CorrelationIdInActingVersion 

func (c *Challenge) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*Challenge) CorrelationIdMaxValue 

func (*Challenge) CorrelationIdMaxValue() int64

func (*Challenge) CorrelationIdMetaAttribute 

func (*Challenge) CorrelationIdMetaAttribute(meta int) string

func (*Challenge) CorrelationIdMinValue 

func (*Challenge) CorrelationIdMinValue() int64

func (*Challenge) CorrelationIdNullValue 

func (*Challenge) CorrelationIdNullValue() int64

func (*Challenge) CorrelationIdSinceVersion 

func (*Challenge) CorrelationIdSinceVersion() uint16

func (*Challenge) Decode 

func (c *Challenge) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*Challenge) Encode 

func (c *Challenge) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (Challenge) EncodedChallengeCharacterEncoding 

func (Challenge) EncodedChallengeCharacterEncoding() string

func (*Challenge) EncodedChallengeDeprecated 

func (*Challenge) EncodedChallengeDeprecated() uint16

func (Challenge) EncodedChallengeHeaderLength 

func (Challenge) EncodedChallengeHeaderLength() uint64

func (*Challenge) EncodedChallengeInActingVersion 

func (c *Challenge) EncodedChallengeInActingVersion(actingVersion uint16) bool

func (*Challenge) EncodedChallengeMetaAttribute 

func (*Challenge) EncodedChallengeMetaAttribute(meta int) string

func (*Challenge) EncodedChallengeSinceVersion 

func (*Challenge) EncodedChallengeSinceVersion() uint16

func (*Challenge) RangeCheck 

func (c *Challenge) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*Challenge) SbeBlockLength 

func (*Challenge) SbeBlockLength() (blockLength uint16)

func (*Challenge) SbeSchemaId 

func (*Challenge) SbeSchemaId() (schemaId uint16)

func (*Challenge) SbeSchemaVersion 

func (*Challenge) SbeSchemaVersion() (schemaVersion uint16)

func (*Challenge) SbeSemanticType 

func (*Challenge) SbeSemanticType() (semanticType []byte)

func (*Challenge) SbeTemplateId 

func (*Challenge) SbeTemplateId() (templateId uint16)

func (*Challenge) VersionDeprecated 

func (*Challenge) VersionDeprecated() uint16

func (*Challenge) VersionId 

func (*Challenge) VersionId() uint16

func (*Challenge) VersionInActingVersion 

func (c *Challenge) VersionInActingVersion(actingVersion uint16) bool

func (*Challenge) VersionMaxValue 

func (*Challenge) VersionMaxValue() int32

func (*Challenge) VersionMetaAttribute 

func (*Challenge) VersionMetaAttribute(meta int) string

func (*Challenge) VersionMinValue 

func (*Challenge) VersionMinValue() int32

func (*Challenge) VersionNullValue 

func (*Challenge) VersionNullValue() int32

func (*Challenge) VersionSinceVersion 

func (*Challenge) VersionSinceVersion() uint16

type ChallengeResponse 

type ChallengeResponse struct {
	ControlSessionId   int64
	CorrelationId      int64
	EncodedCredentials []uint8
}

func (*ChallengeResponse) ControlSessionIdDeprecated 

func (*ChallengeResponse) ControlSessionIdDeprecated() uint16

func (*ChallengeResponse) ControlSessionIdId 

func (*ChallengeResponse) ControlSessionIdId() uint16

func (*ChallengeResponse) ControlSessionIdInActingVersion 

func (c *ChallengeResponse) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ChallengeResponse) ControlSessionIdMaxValue 

func (*ChallengeResponse) ControlSessionIdMaxValue() int64

func (*ChallengeResponse) ControlSessionIdMetaAttribute 

func (*ChallengeResponse) ControlSessionIdMetaAttribute(meta int) string

func (*ChallengeResponse) ControlSessionIdMinValue 

func (*ChallengeResponse) ControlSessionIdMinValue() int64

func (*ChallengeResponse) ControlSessionIdNullValue 

func (*ChallengeResponse) ControlSessionIdNullValue() int64

func (*ChallengeResponse) ControlSessionIdSinceVersion 

func (*ChallengeResponse) ControlSessionIdSinceVersion() uint16

func (*ChallengeResponse) CorrelationIdDeprecated 

func (*ChallengeResponse) CorrelationIdDeprecated() uint16

func (*ChallengeResponse) CorrelationIdId 

func (*ChallengeResponse) CorrelationIdId() uint16

func (*ChallengeResponse) CorrelationIdInActingVersion 

func (c *ChallengeResponse) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ChallengeResponse) CorrelationIdMaxValue 

func (*ChallengeResponse) CorrelationIdMaxValue() int64

func (*ChallengeResponse) CorrelationIdMetaAttribute 

func (*ChallengeResponse) CorrelationIdMetaAttribute(meta int) string

func (*ChallengeResponse) CorrelationIdMinValue 

func (*ChallengeResponse) CorrelationIdMinValue() int64

func (*ChallengeResponse) CorrelationIdNullValue 

func (*ChallengeResponse) CorrelationIdNullValue() int64

func (*ChallengeResponse) CorrelationIdSinceVersion 

func (*ChallengeResponse) CorrelationIdSinceVersion() uint16

func (*ChallengeResponse) Decode 

func (c *ChallengeResponse) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ChallengeResponse) Encode 

func (c *ChallengeResponse) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (ChallengeResponse) EncodedCredentialsCharacterEncoding 

func (ChallengeResponse) EncodedCredentialsCharacterEncoding() string

func (*ChallengeResponse) EncodedCredentialsDeprecated 

func (*ChallengeResponse) EncodedCredentialsDeprecated() uint16

func (ChallengeResponse) EncodedCredentialsHeaderLength 

func (ChallengeResponse) EncodedCredentialsHeaderLength() uint64

func (*ChallengeResponse) EncodedCredentialsInActingVersion 

func (c *ChallengeResponse) EncodedCredentialsInActingVersion(actingVersion uint16) bool

func (*ChallengeResponse) EncodedCredentialsMetaAttribute 

func (*ChallengeResponse) EncodedCredentialsMetaAttribute(meta int) string

func (*ChallengeResponse) EncodedCredentialsSinceVersion 

func (*ChallengeResponse) EncodedCredentialsSinceVersion() uint16

func (*ChallengeResponse) RangeCheck 

func (c *ChallengeResponse) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ChallengeResponse) SbeBlockLength 

func (*ChallengeResponse) SbeBlockLength() (blockLength uint16)

func (*ChallengeResponse) SbeSchemaId 

func (*ChallengeResponse) SbeSchemaId() (schemaId uint16)

func (*ChallengeResponse) SbeSchemaVersion 

func (*ChallengeResponse) SbeSchemaVersion() (schemaVersion uint16)

func (*ChallengeResponse) SbeSemanticType 

func (*ChallengeResponse) SbeSemanticType() (semanticType []byte)

func (*ChallengeResponse) SbeTemplateId 

func (*ChallengeResponse) SbeTemplateId() (templateId uint16)

type CloseSessionRequest 

type CloseSessionRequest struct {
	ControlSessionId int64
}

func (*CloseSessionRequest) ControlSessionIdDeprecated 

func (*CloseSessionRequest) ControlSessionIdDeprecated() uint16

func (*CloseSessionRequest) ControlSessionIdId 

func (*CloseSessionRequest) ControlSessionIdId() uint16

func (*CloseSessionRequest) ControlSessionIdInActingVersion 

func (c *CloseSessionRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*CloseSessionRequest) ControlSessionIdMaxValue 

func (*CloseSessionRequest) ControlSessionIdMaxValue() int64

func (*CloseSessionRequest) ControlSessionIdMetaAttribute 

func (*CloseSessionRequest) ControlSessionIdMetaAttribute(meta int) string

func (*CloseSessionRequest) ControlSessionIdMinValue 

func (*CloseSessionRequest) ControlSessionIdMinValue() int64

func (*CloseSessionRequest) ControlSessionIdNullValue 

func (*CloseSessionRequest) ControlSessionIdNullValue() int64

func (*CloseSessionRequest) ControlSessionIdSinceVersion 

func (*CloseSessionRequest) ControlSessionIdSinceVersion() uint16

func (*CloseSessionRequest) Decode 

func (c *CloseSessionRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*CloseSessionRequest) Encode 

func (c *CloseSessionRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*CloseSessionRequest) RangeCheck 

func (c *CloseSessionRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*CloseSessionRequest) SbeBlockLength 

func (*CloseSessionRequest) SbeBlockLength() (blockLength uint16)

func (*CloseSessionRequest) SbeSchemaId 

func (*CloseSessionRequest) SbeSchemaId() (schemaId uint16)

func (*CloseSessionRequest) SbeSchemaVersion 

func (*CloseSessionRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*CloseSessionRequest) SbeSemanticType 

func (*CloseSessionRequest) SbeSemanticType() (semanticType []byte)

func (*CloseSessionRequest) SbeTemplateId 

func (*CloseSessionRequest) SbeTemplateId() (templateId uint16)

type ConnectRequest 

type ConnectRequest struct {
	CorrelationId    int64
	ResponseStreamId int32
	Version          int32
	ResponseChannel  []uint8
}

func (*ConnectRequest) CorrelationIdDeprecated 

func (*ConnectRequest) CorrelationIdDeprecated() uint16

func (*ConnectRequest) CorrelationIdId 

func (*ConnectRequest) CorrelationIdId() uint16

func (*ConnectRequest) CorrelationIdInActingVersion 

func (c *ConnectRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ConnectRequest) CorrelationIdMaxValue 

func (*ConnectRequest) CorrelationIdMaxValue() int64

func (*ConnectRequest) CorrelationIdMetaAttribute 

func (*ConnectRequest) CorrelationIdMetaAttribute(meta int) string

func (*ConnectRequest) CorrelationIdMinValue 

func (*ConnectRequest) CorrelationIdMinValue() int64

func (*ConnectRequest) CorrelationIdNullValue 

func (*ConnectRequest) CorrelationIdNullValue() int64

func (*ConnectRequest) CorrelationIdSinceVersion 

func (*ConnectRequest) CorrelationIdSinceVersion() uint16

func (*ConnectRequest) Decode 

func (c *ConnectRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ConnectRequest) Encode 

func (c *ConnectRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*ConnectRequest) RangeCheck 

func (c *ConnectRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (ConnectRequest) ResponseChannelCharacterEncoding 

func (ConnectRequest) ResponseChannelCharacterEncoding() string

func (*ConnectRequest) ResponseChannelDeprecated 

func (*ConnectRequest) ResponseChannelDeprecated() uint16

func (ConnectRequest) ResponseChannelHeaderLength 

func (ConnectRequest) ResponseChannelHeaderLength() uint64

func (*ConnectRequest) ResponseChannelInActingVersion 

func (c *ConnectRequest) ResponseChannelInActingVersion(actingVersion uint16) bool

func (*ConnectRequest) ResponseChannelMetaAttribute 

func (*ConnectRequest) ResponseChannelMetaAttribute(meta int) string

func (*ConnectRequest) ResponseChannelSinceVersion 

func (*ConnectRequest) ResponseChannelSinceVersion() uint16

func (*ConnectRequest) ResponseStreamIdDeprecated 

func (*ConnectRequest) ResponseStreamIdDeprecated() uint16

func (*ConnectRequest) ResponseStreamIdId 

func (*ConnectRequest) ResponseStreamIdId() uint16

func (*ConnectRequest) ResponseStreamIdInActingVersion 

func (c *ConnectRequest) ResponseStreamIdInActingVersion(actingVersion uint16) bool

func (*ConnectRequest) ResponseStreamIdMaxValue 

func (*ConnectRequest) ResponseStreamIdMaxValue() int32

func (*ConnectRequest) ResponseStreamIdMetaAttribute 

func (*ConnectRequest) ResponseStreamIdMetaAttribute(meta int) string

func (*ConnectRequest) ResponseStreamIdMinValue 

func (*ConnectRequest) ResponseStreamIdMinValue() int32

func (*ConnectRequest) ResponseStreamIdNullValue 

func (*ConnectRequest) ResponseStreamIdNullValue() int32

func (*ConnectRequest) ResponseStreamIdSinceVersion 

func (*ConnectRequest) ResponseStreamIdSinceVersion() uint16

func (*ConnectRequest) SbeBlockLength 

func (*ConnectRequest) SbeBlockLength() (blockLength uint16)

func (*ConnectRequest) SbeSchemaId 

func (*ConnectRequest) SbeSchemaId() (schemaId uint16)

func (*ConnectRequest) SbeSchemaVersion 

func (*ConnectRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*ConnectRequest) SbeSemanticType 

func (*ConnectRequest) SbeSemanticType() (semanticType []byte)

func (*ConnectRequest) SbeTemplateId 

func (*ConnectRequest) SbeTemplateId() (templateId uint16)

func (*ConnectRequest) VersionDeprecated 

func (*ConnectRequest) VersionDeprecated() uint16

func (*ConnectRequest) VersionId 

func (*ConnectRequest) VersionId() uint16

func (*ConnectRequest) VersionInActingVersion 

func (c *ConnectRequest) VersionInActingVersion(actingVersion uint16) bool

func (*ConnectRequest) VersionMaxValue 

func (*ConnectRequest) VersionMaxValue() int32

func (*ConnectRequest) VersionMetaAttribute 

func (*ConnectRequest) VersionMetaAttribute(meta int) string

func (*ConnectRequest) VersionMinValue 

func (*ConnectRequest) VersionMinValue() int32

func (*ConnectRequest) VersionNullValue 

func (*ConnectRequest) VersionNullValue() int32

func (*ConnectRequest) VersionSinceVersion 

func (*ConnectRequest) VersionSinceVersion() uint16

type ControlResponse 

type ControlResponse struct {
	ControlSessionId int64
	CorrelationId    int64
	RelevantId       int64
	Code             ControlResponseCodeEnum
	Version          int32
	ErrorMessage     []uint8
}

func (*ControlResponse) CodeDeprecated 

func (*ControlResponse) CodeDeprecated() uint16

func (*ControlResponse) CodeId 

func (*ControlResponse) CodeId() uint16

func (*ControlResponse) CodeInActingVersion 

func (c *ControlResponse) CodeInActingVersion(actingVersion uint16) bool

func (*ControlResponse) CodeMetaAttribute 

func (*ControlResponse) CodeMetaAttribute(meta int) string

func (*ControlResponse) CodeSinceVersion 

func (*ControlResponse) CodeSinceVersion() uint16

func (*ControlResponse) ControlSessionIdDeprecated 

func (*ControlResponse) ControlSessionIdDeprecated() uint16

func (*ControlResponse) ControlSessionIdId 

func (*ControlResponse) ControlSessionIdId() uint16

func (*ControlResponse) ControlSessionIdInActingVersion 

func (c *ControlResponse) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ControlResponse) ControlSessionIdMaxValue 

func (*ControlResponse) ControlSessionIdMaxValue() int64

func (*ControlResponse) ControlSessionIdMetaAttribute 

func (*ControlResponse) ControlSessionIdMetaAttribute(meta int) string

func (*ControlResponse) ControlSessionIdMinValue 

func (*ControlResponse) ControlSessionIdMinValue() int64

func (*ControlResponse) ControlSessionIdNullValue 

func (*ControlResponse) ControlSessionIdNullValue() int64

func (*ControlResponse) ControlSessionIdSinceVersion 

func (*ControlResponse) ControlSessionIdSinceVersion() uint16

func (*ControlResponse) CorrelationIdDeprecated 

func (*ControlResponse) CorrelationIdDeprecated() uint16

func (*ControlResponse) CorrelationIdId 

func (*ControlResponse) CorrelationIdId() uint16

func (*ControlResponse) CorrelationIdInActingVersion 

func (c *ControlResponse) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ControlResponse) CorrelationIdMaxValue 

func (*ControlResponse) CorrelationIdMaxValue() int64

func (*ControlResponse) CorrelationIdMetaAttribute 

func (*ControlResponse) CorrelationIdMetaAttribute(meta int) string

func (*ControlResponse) CorrelationIdMinValue 

func (*ControlResponse) CorrelationIdMinValue() int64

func (*ControlResponse) CorrelationIdNullValue 

func (*ControlResponse) CorrelationIdNullValue() int64

func (*ControlResponse) CorrelationIdSinceVersion 

func (*ControlResponse) CorrelationIdSinceVersion() uint16

func (*ControlResponse) Decode 

func (c *ControlResponse) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ControlResponse) Encode 

func (c *ControlResponse) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (ControlResponse) ErrorMessageCharacterEncoding 

func (ControlResponse) ErrorMessageCharacterEncoding() string

func (*ControlResponse) ErrorMessageDeprecated 

func (*ControlResponse) ErrorMessageDeprecated() uint16

func (ControlResponse) ErrorMessageHeaderLength 

func (ControlResponse) ErrorMessageHeaderLength() uint64

func (*ControlResponse) ErrorMessageInActingVersion 

func (c *ControlResponse) ErrorMessageInActingVersion(actingVersion uint16) bool

func (*ControlResponse) ErrorMessageMetaAttribute 

func (*ControlResponse) ErrorMessageMetaAttribute(meta int) string

func (*ControlResponse) ErrorMessageSinceVersion 

func (*ControlResponse) ErrorMessageSinceVersion() uint16

func (*ControlResponse) RangeCheck 

func (c *ControlResponse) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ControlResponse) RelevantIdDeprecated 

func (*ControlResponse) RelevantIdDeprecated() uint16

func (*ControlResponse) RelevantIdId 

func (*ControlResponse) RelevantIdId() uint16

func (*ControlResponse) RelevantIdInActingVersion 

func (c *ControlResponse) RelevantIdInActingVersion(actingVersion uint16) bool

func (*ControlResponse) RelevantIdMaxValue 

func (*ControlResponse) RelevantIdMaxValue() int64

func (*ControlResponse) RelevantIdMetaAttribute 

func (*ControlResponse) RelevantIdMetaAttribute(meta int) string

func (*ControlResponse) RelevantIdMinValue 

func (*ControlResponse) RelevantIdMinValue() int64

func (*ControlResponse) RelevantIdNullValue 

func (*ControlResponse) RelevantIdNullValue() int64

func (*ControlResponse) RelevantIdSinceVersion 

func (*ControlResponse) RelevantIdSinceVersion() uint16

func (*ControlResponse) SbeBlockLength 

func (*ControlResponse) SbeBlockLength() (blockLength uint16)

func (*ControlResponse) SbeSchemaId 

func (*ControlResponse) SbeSchemaId() (schemaId uint16)

func (*ControlResponse) SbeSchemaVersion 

func (*ControlResponse) SbeSchemaVersion() (schemaVersion uint16)

func (*ControlResponse) SbeSemanticType 

func (*ControlResponse) SbeSemanticType() (semanticType []byte)

func (*ControlResponse) SbeTemplateId 

func (*ControlResponse) SbeTemplateId() (templateId uint16)

func (*ControlResponse) VersionDeprecated 

func (*ControlResponse) VersionDeprecated() uint16

func (*ControlResponse) VersionId 

func (*ControlResponse) VersionId() uint16

func (*ControlResponse) VersionInActingVersion 

func (c *ControlResponse) VersionInActingVersion(actingVersion uint16) bool

func (*ControlResponse) VersionMaxValue 

func (*ControlResponse) VersionMaxValue() int32

func (*ControlResponse) VersionMetaAttribute 

func (*ControlResponse) VersionMetaAttribute(meta int) string

func (*ControlResponse) VersionMinValue 

func (*ControlResponse) VersionMinValue() int32

func (*ControlResponse) VersionNullValue 

func (*ControlResponse) VersionNullValue() int32

func (*ControlResponse) VersionSinceVersion 

func (*ControlResponse) VersionSinceVersion() uint16

type ControlResponseCodeEnum 

type ControlResponseCodeEnum int32

func (*ControlResponseCodeEnum) Decode 

func (c *ControlResponseCodeEnum) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16) error

func (*ControlResponseCodeEnum) ERRORDeprecated 

func (*ControlResponseCodeEnum) ERRORDeprecated() uint16

func (*ControlResponseCodeEnum) ERRORInActingVersion 

func (c *ControlResponseCodeEnum) ERRORInActingVersion(actingVersion uint16) bool

func (*ControlResponseCodeEnum) ERRORSinceVersion 

func (*ControlResponseCodeEnum) ERRORSinceVersion() uint16

func (ControlResponseCodeEnum) Encode 

func (c ControlResponseCodeEnum) Encode(_m *SbeGoMarshaller, _w io.Writer) error

func (*ControlResponseCodeEnum) EncodedLength 

func (*ControlResponseCodeEnum) EncodedLength() int64

func (*ControlResponseCodeEnum) OKDeprecated 

func (*ControlResponseCodeEnum) OKDeprecated() uint16

func (*ControlResponseCodeEnum) OKInActingVersion 

func (c *ControlResponseCodeEnum) OKInActingVersion(actingVersion uint16) bool

func (*ControlResponseCodeEnum) OKSinceVersion 

func (*ControlResponseCodeEnum) OKSinceVersion() uint16

func (*ControlResponseCodeEnum) RECORDING_UNKNOWNDeprecated 

func (*ControlResponseCodeEnum) RECORDING_UNKNOWNDeprecated() uint16

func (*ControlResponseCodeEnum) RECORDING_UNKNOWNInActingVersion 

func (c *ControlResponseCodeEnum) RECORDING_UNKNOWNInActingVersion(actingVersion uint16) bool

func (*ControlResponseCodeEnum) RECORDING_UNKNOWNSinceVersion 

func (*ControlResponseCodeEnum) RECORDING_UNKNOWNSinceVersion() uint16

func (ControlResponseCodeEnum) RangeCheck 

func (c ControlResponseCodeEnum) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ControlResponseCodeEnum) SUBSCRIPTION_UNKNOWNDeprecated 

func (*ControlResponseCodeEnum) SUBSCRIPTION_UNKNOWNDeprecated() uint16

func (*ControlResponseCodeEnum) SUBSCRIPTION_UNKNOWNInActingVersion 

func (c *ControlResponseCodeEnum) SUBSCRIPTION_UNKNOWNInActingVersion(actingVersion uint16) bool

func (*ControlResponseCodeEnum) SUBSCRIPTION_UNKNOWNSinceVersion 

func (*ControlResponseCodeEnum) SUBSCRIPTION_UNKNOWNSinceVersion() uint16

type ControlResponseCodeValues 

type ControlResponseCodeValues struct {
	OK                   ControlResponseCodeEnum
	ERROR                ControlResponseCodeEnum
	RECORDING_UNKNOWN    ControlResponseCodeEnum
	SUBSCRIPTION_UNKNOWN ControlResponseCodeEnum
	NullValue            ControlResponseCodeEnum
}

type DeleteDetachedSegmentsRequest 

type DeleteDetachedSegmentsRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
}

func (*DeleteDetachedSegmentsRequest) ControlSessionIdDeprecated 

func (*DeleteDetachedSegmentsRequest) ControlSessionIdDeprecated() uint16

func (*DeleteDetachedSegmentsRequest) ControlSessionIdId 

func (*DeleteDetachedSegmentsRequest) ControlSessionIdId() uint16

func (*DeleteDetachedSegmentsRequest) ControlSessionIdInActingVersion 

func (d *DeleteDetachedSegmentsRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*DeleteDetachedSegmentsRequest) ControlSessionIdMaxValue 

func (*DeleteDetachedSegmentsRequest) ControlSessionIdMaxValue() int64

func (*DeleteDetachedSegmentsRequest) ControlSessionIdMetaAttribute 

func (*DeleteDetachedSegmentsRequest) ControlSessionIdMetaAttribute(meta int) string

func (*DeleteDetachedSegmentsRequest) ControlSessionIdMinValue 

func (*DeleteDetachedSegmentsRequest) ControlSessionIdMinValue() int64

func (*DeleteDetachedSegmentsRequest) ControlSessionIdNullValue 

func (*DeleteDetachedSegmentsRequest) ControlSessionIdNullValue() int64

func (*DeleteDetachedSegmentsRequest) ControlSessionIdSinceVersion 

func (*DeleteDetachedSegmentsRequest) ControlSessionIdSinceVersion() uint16

func (*DeleteDetachedSegmentsRequest) CorrelationIdDeprecated 

func (*DeleteDetachedSegmentsRequest) CorrelationIdDeprecated() uint16

func (*DeleteDetachedSegmentsRequest) CorrelationIdId 

func (*DeleteDetachedSegmentsRequest) CorrelationIdId() uint16

func (*DeleteDetachedSegmentsRequest) CorrelationIdInActingVersion 

func (d *DeleteDetachedSegmentsRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*DeleteDetachedSegmentsRequest) CorrelationIdMaxValue 

func (*DeleteDetachedSegmentsRequest) CorrelationIdMaxValue() int64

func (*DeleteDetachedSegmentsRequest) CorrelationIdMetaAttribute 

func (*DeleteDetachedSegmentsRequest) CorrelationIdMetaAttribute(meta int) string

func (*DeleteDetachedSegmentsRequest) CorrelationIdMinValue 

func (*DeleteDetachedSegmentsRequest) CorrelationIdMinValue() int64

func (*DeleteDetachedSegmentsRequest) CorrelationIdNullValue 

func (*DeleteDetachedSegmentsRequest) CorrelationIdNullValue() int64

func (*DeleteDetachedSegmentsRequest) CorrelationIdSinceVersion 

func (*DeleteDetachedSegmentsRequest) CorrelationIdSinceVersion() uint16

func (*DeleteDetachedSegmentsRequest) Decode 

func (d *DeleteDetachedSegmentsRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*DeleteDetachedSegmentsRequest) Encode 

func (d *DeleteDetachedSegmentsRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*DeleteDetachedSegmentsRequest) RangeCheck 

func (d *DeleteDetachedSegmentsRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*DeleteDetachedSegmentsRequest) RecordingIdDeprecated 

func (*DeleteDetachedSegmentsRequest) RecordingIdDeprecated() uint16

func (*DeleteDetachedSegmentsRequest) RecordingIdId 

func (*DeleteDetachedSegmentsRequest) RecordingIdId() uint16

func (*DeleteDetachedSegmentsRequest) RecordingIdInActingVersion 

func (d *DeleteDetachedSegmentsRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*DeleteDetachedSegmentsRequest) RecordingIdMaxValue 

func (*DeleteDetachedSegmentsRequest) RecordingIdMaxValue() int64

func (*DeleteDetachedSegmentsRequest) RecordingIdMetaAttribute 

func (*DeleteDetachedSegmentsRequest) RecordingIdMetaAttribute(meta int) string

func (*DeleteDetachedSegmentsRequest) RecordingIdMinValue 

func (*DeleteDetachedSegmentsRequest) RecordingIdMinValue() int64

func (*DeleteDetachedSegmentsRequest) RecordingIdNullValue 

func (*DeleteDetachedSegmentsRequest) RecordingIdNullValue() int64

func (*DeleteDetachedSegmentsRequest) RecordingIdSinceVersion 

func (*DeleteDetachedSegmentsRequest) RecordingIdSinceVersion() uint16

func (*DeleteDetachedSegmentsRequest) SbeBlockLength 

func (*DeleteDetachedSegmentsRequest) SbeBlockLength() (blockLength uint16)

func (*DeleteDetachedSegmentsRequest) SbeSchemaId 

func (*DeleteDetachedSegmentsRequest) SbeSchemaId() (schemaId uint16)

func (*DeleteDetachedSegmentsRequest) SbeSchemaVersion 

func (*DeleteDetachedSegmentsRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*DeleteDetachedSegmentsRequest) SbeSemanticType 

func (*DeleteDetachedSegmentsRequest) SbeSemanticType() (semanticType []byte)

func (*DeleteDetachedSegmentsRequest) SbeTemplateId 

func (*DeleteDetachedSegmentsRequest) SbeTemplateId() (templateId uint16)

type DetachSegmentsRequest 

type DetachSegmentsRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
	NewStartPosition int64
}

func (*DetachSegmentsRequest) ControlSessionIdDeprecated 

func (*DetachSegmentsRequest) ControlSessionIdDeprecated() uint16

func (*DetachSegmentsRequest) ControlSessionIdId 

func (*DetachSegmentsRequest) ControlSessionIdId() uint16

func (*DetachSegmentsRequest) ControlSessionIdInActingVersion 

func (d *DetachSegmentsRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*DetachSegmentsRequest) ControlSessionIdMaxValue 

func (*DetachSegmentsRequest) ControlSessionIdMaxValue() int64

func (*DetachSegmentsRequest) ControlSessionIdMetaAttribute 

func (*DetachSegmentsRequest) ControlSessionIdMetaAttribute(meta int) string

func (*DetachSegmentsRequest) ControlSessionIdMinValue 

func (*DetachSegmentsRequest) ControlSessionIdMinValue() int64

func (*DetachSegmentsRequest) ControlSessionIdNullValue 

func (*DetachSegmentsRequest) ControlSessionIdNullValue() int64

func (*DetachSegmentsRequest) ControlSessionIdSinceVersion 

func (*DetachSegmentsRequest) ControlSessionIdSinceVersion() uint16

func (*DetachSegmentsRequest) CorrelationIdDeprecated 

func (*DetachSegmentsRequest) CorrelationIdDeprecated() uint16

func (*DetachSegmentsRequest) CorrelationIdId 

func (*DetachSegmentsRequest) CorrelationIdId() uint16

func (*DetachSegmentsRequest) CorrelationIdInActingVersion 

func (d *DetachSegmentsRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*DetachSegmentsRequest) CorrelationIdMaxValue 

func (*DetachSegmentsRequest) CorrelationIdMaxValue() int64

func (*DetachSegmentsRequest) CorrelationIdMetaAttribute 

func (*DetachSegmentsRequest) CorrelationIdMetaAttribute(meta int) string

func (*DetachSegmentsRequest) CorrelationIdMinValue 

func (*DetachSegmentsRequest) CorrelationIdMinValue() int64

func (*DetachSegmentsRequest) CorrelationIdNullValue 

func (*DetachSegmentsRequest) CorrelationIdNullValue() int64

func (*DetachSegmentsRequest) CorrelationIdSinceVersion 

func (*DetachSegmentsRequest) CorrelationIdSinceVersion() uint16

func (*DetachSegmentsRequest) Decode 

func (d *DetachSegmentsRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*DetachSegmentsRequest) Encode 

func (d *DetachSegmentsRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*DetachSegmentsRequest) NewStartPositionDeprecated 

func (*DetachSegmentsRequest) NewStartPositionDeprecated() uint16

func (*DetachSegmentsRequest) NewStartPositionId 

func (*DetachSegmentsRequest) NewStartPositionId() uint16

func (*DetachSegmentsRequest) NewStartPositionInActingVersion 

func (d *DetachSegmentsRequest) NewStartPositionInActingVersion(actingVersion uint16) bool

func (*DetachSegmentsRequest) NewStartPositionMaxValue 

func (*DetachSegmentsRequest) NewStartPositionMaxValue() int64

func (*DetachSegmentsRequest) NewStartPositionMetaAttribute 

func (*DetachSegmentsRequest) NewStartPositionMetaAttribute(meta int) string

func (*DetachSegmentsRequest) NewStartPositionMinValue 

func (*DetachSegmentsRequest) NewStartPositionMinValue() int64

func (*DetachSegmentsRequest) NewStartPositionNullValue 

func (*DetachSegmentsRequest) NewStartPositionNullValue() int64

func (*DetachSegmentsRequest) NewStartPositionSinceVersion 

func (*DetachSegmentsRequest) NewStartPositionSinceVersion() uint16

func (*DetachSegmentsRequest) RangeCheck 

func (d *DetachSegmentsRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*DetachSegmentsRequest) RecordingIdDeprecated 

func (*DetachSegmentsRequest) RecordingIdDeprecated() uint16

func (*DetachSegmentsRequest) RecordingIdId 

func (*DetachSegmentsRequest) RecordingIdId() uint16

func (*DetachSegmentsRequest) RecordingIdInActingVersion 

func (d *DetachSegmentsRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*DetachSegmentsRequest) RecordingIdMaxValue 

func (*DetachSegmentsRequest) RecordingIdMaxValue() int64

func (*DetachSegmentsRequest) RecordingIdMetaAttribute 

func (*DetachSegmentsRequest) RecordingIdMetaAttribute(meta int) string

func (*DetachSegmentsRequest) RecordingIdMinValue 

func (*DetachSegmentsRequest) RecordingIdMinValue() int64

func (*DetachSegmentsRequest) RecordingIdNullValue 

func (*DetachSegmentsRequest) RecordingIdNullValue() int64

func (*DetachSegmentsRequest) RecordingIdSinceVersion 

func (*DetachSegmentsRequest) RecordingIdSinceVersion() uint16

func (*DetachSegmentsRequest) SbeBlockLength 

func (*DetachSegmentsRequest) SbeBlockLength() (blockLength uint16)

func (*DetachSegmentsRequest) SbeSchemaId 

func (*DetachSegmentsRequest) SbeSchemaId() (schemaId uint16)

func (*DetachSegmentsRequest) SbeSchemaVersion 

func (*DetachSegmentsRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*DetachSegmentsRequest) SbeSemanticType 

func (*DetachSegmentsRequest) SbeSemanticType() (semanticType []byte)

func (*DetachSegmentsRequest) SbeTemplateId 

func (*DetachSegmentsRequest) SbeTemplateId() (templateId uint16)

type ExtendRecordingRequest 

type ExtendRecordingRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
	StreamId         int32
	SourceLocation   SourceLocationEnum
	Channel          []uint8
}

func (ExtendRecordingRequest) ChannelCharacterEncoding 

func (ExtendRecordingRequest) ChannelCharacterEncoding() string

func (*ExtendRecordingRequest) ChannelDeprecated 

func (*ExtendRecordingRequest) ChannelDeprecated() uint16

func (ExtendRecordingRequest) ChannelHeaderLength 

func (ExtendRecordingRequest) ChannelHeaderLength() uint64

func (*ExtendRecordingRequest) ChannelInActingVersion 

func (e *ExtendRecordingRequest) ChannelInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest) ChannelMetaAttribute 

func (*ExtendRecordingRequest) ChannelMetaAttribute(meta int) string

func (*ExtendRecordingRequest) ChannelSinceVersion 

func (*ExtendRecordingRequest) ChannelSinceVersion() uint16

func (*ExtendRecordingRequest) ControlSessionIdDeprecated 

func (*ExtendRecordingRequest) ControlSessionIdDeprecated() uint16

func (*ExtendRecordingRequest) ControlSessionIdId 

func (*ExtendRecordingRequest) ControlSessionIdId() uint16

func (*ExtendRecordingRequest) ControlSessionIdInActingVersion 

func (e *ExtendRecordingRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest) ControlSessionIdMaxValue 

func (*ExtendRecordingRequest) ControlSessionIdMaxValue() int64

func (*ExtendRecordingRequest) ControlSessionIdMetaAttribute 

func (*ExtendRecordingRequest) ControlSessionIdMetaAttribute(meta int) string

func (*ExtendRecordingRequest) ControlSessionIdMinValue 

func (*ExtendRecordingRequest) ControlSessionIdMinValue() int64

func (*ExtendRecordingRequest) ControlSessionIdNullValue 

func (*ExtendRecordingRequest) ControlSessionIdNullValue() int64

func (*ExtendRecordingRequest) ControlSessionIdSinceVersion 

func (*ExtendRecordingRequest) ControlSessionIdSinceVersion() uint16

func (*ExtendRecordingRequest) CorrelationIdDeprecated 

func (*ExtendRecordingRequest) CorrelationIdDeprecated() uint16

func (*ExtendRecordingRequest) CorrelationIdId 

func (*ExtendRecordingRequest) CorrelationIdId() uint16

func (*ExtendRecordingRequest) CorrelationIdInActingVersion 

func (e *ExtendRecordingRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest) CorrelationIdMaxValue 

func (*ExtendRecordingRequest) CorrelationIdMaxValue() int64

func (*ExtendRecordingRequest) CorrelationIdMetaAttribute 

func (*ExtendRecordingRequest) CorrelationIdMetaAttribute(meta int) string

func (*ExtendRecordingRequest) CorrelationIdMinValue 

func (*ExtendRecordingRequest) CorrelationIdMinValue() int64

func (*ExtendRecordingRequest) CorrelationIdNullValue 

func (*ExtendRecordingRequest) CorrelationIdNullValue() int64

func (*ExtendRecordingRequest) CorrelationIdSinceVersion 

func (*ExtendRecordingRequest) CorrelationIdSinceVersion() uint16

func (*ExtendRecordingRequest) Decode 

func (e *ExtendRecordingRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ExtendRecordingRequest) Encode 

func (e *ExtendRecordingRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*ExtendRecordingRequest) RangeCheck 

func (e *ExtendRecordingRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ExtendRecordingRequest) RecordingIdDeprecated 

func (*ExtendRecordingRequest) RecordingIdDeprecated() uint16

func (*ExtendRecordingRequest) RecordingIdId 

func (*ExtendRecordingRequest) RecordingIdId() uint16

func (*ExtendRecordingRequest) RecordingIdInActingVersion 

func (e *ExtendRecordingRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest) RecordingIdMaxValue 

func (*ExtendRecordingRequest) RecordingIdMaxValue() int64

func (*ExtendRecordingRequest) RecordingIdMetaAttribute 

func (*ExtendRecordingRequest) RecordingIdMetaAttribute(meta int) string

func (*ExtendRecordingRequest) RecordingIdMinValue 

func (*ExtendRecordingRequest) RecordingIdMinValue() int64

func (*ExtendRecordingRequest) RecordingIdNullValue 

func (*ExtendRecordingRequest) RecordingIdNullValue() int64

func (*ExtendRecordingRequest) RecordingIdSinceVersion 

func (*ExtendRecordingRequest) RecordingIdSinceVersion() uint16

func (*ExtendRecordingRequest) SbeBlockLength 

func (*ExtendRecordingRequest) SbeBlockLength() (blockLength uint16)

func (*ExtendRecordingRequest) SbeSchemaId 

func (*ExtendRecordingRequest) SbeSchemaId() (schemaId uint16)

func (*ExtendRecordingRequest) SbeSchemaVersion 

func (*ExtendRecordingRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*ExtendRecordingRequest) SbeSemanticType 

func (*ExtendRecordingRequest) SbeSemanticType() (semanticType []byte)

func (*ExtendRecordingRequest) SbeTemplateId 

func (*ExtendRecordingRequest) SbeTemplateId() (templateId uint16)

func (*ExtendRecordingRequest) SourceLocationDeprecated 

func (*ExtendRecordingRequest) SourceLocationDeprecated() uint16

func (*ExtendRecordingRequest) SourceLocationId 

func (*ExtendRecordingRequest) SourceLocationId() uint16

func (*ExtendRecordingRequest) SourceLocationInActingVersion 

func (e *ExtendRecordingRequest) SourceLocationInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest) SourceLocationMetaAttribute 

func (*ExtendRecordingRequest) SourceLocationMetaAttribute(meta int) string

func (*ExtendRecordingRequest) SourceLocationSinceVersion 

func (*ExtendRecordingRequest) SourceLocationSinceVersion() uint16

func (*ExtendRecordingRequest) StreamIdDeprecated 

func (*ExtendRecordingRequest) StreamIdDeprecated() uint16

func (*ExtendRecordingRequest) StreamIdId 

func (*ExtendRecordingRequest) StreamIdId() uint16

func (*ExtendRecordingRequest) StreamIdInActingVersion 

func (e *ExtendRecordingRequest) StreamIdInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest) StreamIdMaxValue 

func (*ExtendRecordingRequest) StreamIdMaxValue() int32

func (*ExtendRecordingRequest) StreamIdMetaAttribute 

func (*ExtendRecordingRequest) StreamIdMetaAttribute(meta int) string

func (*ExtendRecordingRequest) StreamIdMinValue 

func (*ExtendRecordingRequest) StreamIdMinValue() int32

func (*ExtendRecordingRequest) StreamIdNullValue 

func (*ExtendRecordingRequest) StreamIdNullValue() int32

func (*ExtendRecordingRequest) StreamIdSinceVersion 

func (*ExtendRecordingRequest) StreamIdSinceVersion() uint16

type ExtendRecordingRequest2 

type ExtendRecordingRequest2 struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
	StreamId         int32
	SourceLocation   SourceLocationEnum
	AutoStop         BooleanTypeEnum
	Channel          []uint8
}

func (*ExtendRecordingRequest2) AutoStopDeprecated 

func (*ExtendRecordingRequest2) AutoStopDeprecated() uint16

func (*ExtendRecordingRequest2) AutoStopId 

func (*ExtendRecordingRequest2) AutoStopId() uint16

func (*ExtendRecordingRequest2) AutoStopInActingVersion 

func (e *ExtendRecordingRequest2) AutoStopInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest2) AutoStopMetaAttribute 

func (*ExtendRecordingRequest2) AutoStopMetaAttribute(meta int) string

func (*ExtendRecordingRequest2) AutoStopSinceVersion 

func (*ExtendRecordingRequest2) AutoStopSinceVersion() uint16

func (ExtendRecordingRequest2) ChannelCharacterEncoding 

func (ExtendRecordingRequest2) ChannelCharacterEncoding() string

func (*ExtendRecordingRequest2) ChannelDeprecated 

func (*ExtendRecordingRequest2) ChannelDeprecated() uint16

func (ExtendRecordingRequest2) ChannelHeaderLength 

func (ExtendRecordingRequest2) ChannelHeaderLength() uint64

func (*ExtendRecordingRequest2) ChannelInActingVersion 

func (e *ExtendRecordingRequest2) ChannelInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest2) ChannelMetaAttribute 

func (*ExtendRecordingRequest2) ChannelMetaAttribute(meta int) string

func (*ExtendRecordingRequest2) ChannelSinceVersion 

func (*ExtendRecordingRequest2) ChannelSinceVersion() uint16

func (*ExtendRecordingRequest2) ControlSessionIdDeprecated 

func (*ExtendRecordingRequest2) ControlSessionIdDeprecated() uint16

func (*ExtendRecordingRequest2) ControlSessionIdId 

func (*ExtendRecordingRequest2) ControlSessionIdId() uint16

func (*ExtendRecordingRequest2) ControlSessionIdInActingVersion 

func (e *ExtendRecordingRequest2) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest2) ControlSessionIdMaxValue 

func (*ExtendRecordingRequest2) ControlSessionIdMaxValue() int64

func (*ExtendRecordingRequest2) ControlSessionIdMetaAttribute 

func (*ExtendRecordingRequest2) ControlSessionIdMetaAttribute(meta int) string

func (*ExtendRecordingRequest2) ControlSessionIdMinValue 

func (*ExtendRecordingRequest2) ControlSessionIdMinValue() int64

func (*ExtendRecordingRequest2) ControlSessionIdNullValue 

func (*ExtendRecordingRequest2) ControlSessionIdNullValue() int64

func (*ExtendRecordingRequest2) ControlSessionIdSinceVersion 

func (*ExtendRecordingRequest2) ControlSessionIdSinceVersion() uint16

func (*ExtendRecordingRequest2) CorrelationIdDeprecated 

func (*ExtendRecordingRequest2) CorrelationIdDeprecated() uint16

func (*ExtendRecordingRequest2) CorrelationIdId 

func (*ExtendRecordingRequest2) CorrelationIdId() uint16

func (*ExtendRecordingRequest2) CorrelationIdInActingVersion 

func (e *ExtendRecordingRequest2) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest2) CorrelationIdMaxValue 

func (*ExtendRecordingRequest2) CorrelationIdMaxValue() int64

func (*ExtendRecordingRequest2) CorrelationIdMetaAttribute 

func (*ExtendRecordingRequest2) CorrelationIdMetaAttribute(meta int) string

func (*ExtendRecordingRequest2) CorrelationIdMinValue 

func (*ExtendRecordingRequest2) CorrelationIdMinValue() int64

func (*ExtendRecordingRequest2) CorrelationIdNullValue 

func (*ExtendRecordingRequest2) CorrelationIdNullValue() int64

func (*ExtendRecordingRequest2) CorrelationIdSinceVersion 

func (*ExtendRecordingRequest2) CorrelationIdSinceVersion() uint16

func (*ExtendRecordingRequest2) Decode 

func (e *ExtendRecordingRequest2) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ExtendRecordingRequest2) Encode 

func (e *ExtendRecordingRequest2) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*ExtendRecordingRequest2) RangeCheck 

func (e *ExtendRecordingRequest2) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ExtendRecordingRequest2) RecordingIdDeprecated 

func (*ExtendRecordingRequest2) RecordingIdDeprecated() uint16

func (*ExtendRecordingRequest2) RecordingIdId 

func (*ExtendRecordingRequest2) RecordingIdId() uint16

func (*ExtendRecordingRequest2) RecordingIdInActingVersion 

func (e *ExtendRecordingRequest2) RecordingIdInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest2) RecordingIdMaxValue 

func (*ExtendRecordingRequest2) RecordingIdMaxValue() int64

func (*ExtendRecordingRequest2) RecordingIdMetaAttribute 

func (*ExtendRecordingRequest2) RecordingIdMetaAttribute(meta int) string

func (*ExtendRecordingRequest2) RecordingIdMinValue 

func (*ExtendRecordingRequest2) RecordingIdMinValue() int64

func (*ExtendRecordingRequest2) RecordingIdNullValue 

func (*ExtendRecordingRequest2) RecordingIdNullValue() int64

func (*ExtendRecordingRequest2) RecordingIdSinceVersion 

func (*ExtendRecordingRequest2) RecordingIdSinceVersion() uint16

func (*ExtendRecordingRequest2) SbeBlockLength 

func (*ExtendRecordingRequest2) SbeBlockLength() (blockLength uint16)

func (*ExtendRecordingRequest2) SbeSchemaId 

func (*ExtendRecordingRequest2) SbeSchemaId() (schemaId uint16)

func (*ExtendRecordingRequest2) SbeSchemaVersion 

func (*ExtendRecordingRequest2) SbeSchemaVersion() (schemaVersion uint16)

func (*ExtendRecordingRequest2) SbeSemanticType 

func (*ExtendRecordingRequest2) SbeSemanticType() (semanticType []byte)

func (*ExtendRecordingRequest2) SbeTemplateId 

func (*ExtendRecordingRequest2) SbeTemplateId() (templateId uint16)

func (*ExtendRecordingRequest2) SourceLocationDeprecated 

func (*ExtendRecordingRequest2) SourceLocationDeprecated() uint16

func (*ExtendRecordingRequest2) SourceLocationId 

func (*ExtendRecordingRequest2) SourceLocationId() uint16

func (*ExtendRecordingRequest2) SourceLocationInActingVersion 

func (e *ExtendRecordingRequest2) SourceLocationInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest2) SourceLocationMetaAttribute 

func (*ExtendRecordingRequest2) SourceLocationMetaAttribute(meta int) string

func (*ExtendRecordingRequest2) SourceLocationSinceVersion 

func (*ExtendRecordingRequest2) SourceLocationSinceVersion() uint16

func (*ExtendRecordingRequest2) StreamIdDeprecated 

func (*ExtendRecordingRequest2) StreamIdDeprecated() uint16

func (*ExtendRecordingRequest2) StreamIdId 

func (*ExtendRecordingRequest2) StreamIdId() uint16

func (*ExtendRecordingRequest2) StreamIdInActingVersion 

func (e *ExtendRecordingRequest2) StreamIdInActingVersion(actingVersion uint16) bool

func (*ExtendRecordingRequest2) StreamIdMaxValue 

func (*ExtendRecordingRequest2) StreamIdMaxValue() int32

func (*ExtendRecordingRequest2) StreamIdMetaAttribute 

func (*ExtendRecordingRequest2) StreamIdMetaAttribute(meta int) string

func (*ExtendRecordingRequest2) StreamIdMinValue 

func (*ExtendRecordingRequest2) StreamIdMinValue() int32

func (*ExtendRecordingRequest2) StreamIdNullValue 

func (*ExtendRecordingRequest2) StreamIdNullValue() int32

func (*ExtendRecordingRequest2) StreamIdSinceVersion 

func (*ExtendRecordingRequest2) StreamIdSinceVersion() uint16

type FindLastMatchingRecordingRequest 

type FindLastMatchingRecordingRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	MinRecordingId   int64
	SessionId        int32
	StreamId         int32
	Channel          []uint8
}

func (FindLastMatchingRecordingRequest) ChannelCharacterEncoding 

func (FindLastMatchingRecordingRequest) ChannelCharacterEncoding() string

func (*FindLastMatchingRecordingRequest) ChannelDeprecated 

func (*FindLastMatchingRecordingRequest) ChannelDeprecated() uint16

func (FindLastMatchingRecordingRequest) ChannelHeaderLength 

func (FindLastMatchingRecordingRequest) ChannelHeaderLength() uint64

func (*FindLastMatchingRecordingRequest) ChannelInActingVersion 

func (f *FindLastMatchingRecordingRequest) ChannelInActingVersion(actingVersion uint16) bool

func (*FindLastMatchingRecordingRequest) ChannelMetaAttribute 

func (*FindLastMatchingRecordingRequest) ChannelMetaAttribute(meta int) string

func (*FindLastMatchingRecordingRequest) ChannelSinceVersion 

func (*FindLastMatchingRecordingRequest) ChannelSinceVersion() uint16

func (*FindLastMatchingRecordingRequest) ControlSessionIdDeprecated 

func (*FindLastMatchingRecordingRequest) ControlSessionIdDeprecated() uint16

func (*FindLastMatchingRecordingRequest) ControlSessionIdId 

func (*FindLastMatchingRecordingRequest) ControlSessionIdId() uint16

func (*FindLastMatchingRecordingRequest) ControlSessionIdInActingVersion 

func (f *FindLastMatchingRecordingRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*FindLastMatchingRecordingRequest) ControlSessionIdMaxValue 

func (*FindLastMatchingRecordingRequest) ControlSessionIdMaxValue() int64

func (*FindLastMatchingRecordingRequest) ControlSessionIdMetaAttribute 

func (*FindLastMatchingRecordingRequest) ControlSessionIdMetaAttribute(meta int) string

func (*FindLastMatchingRecordingRequest) ControlSessionIdMinValue 

func (*FindLastMatchingRecordingRequest) ControlSessionIdMinValue() int64

func (*FindLastMatchingRecordingRequest) ControlSessionIdNullValue 

func (*FindLastMatchingRecordingRequest) ControlSessionIdNullValue() int64

func (*FindLastMatchingRecordingRequest) ControlSessionIdSinceVersion 

func (*FindLastMatchingRecordingRequest) ControlSessionIdSinceVersion() uint16

func (*FindLastMatchingRecordingRequest) CorrelationIdDeprecated 

func (*FindLastMatchingRecordingRequest) CorrelationIdDeprecated() uint16

func (*FindLastMatchingRecordingRequest) CorrelationIdId 

func (*FindLastMatchingRecordingRequest) CorrelationIdId() uint16

func (*FindLastMatchingRecordingRequest) CorrelationIdInActingVersion 

func (f *FindLastMatchingRecordingRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*FindLastMatchingRecordingRequest) CorrelationIdMaxValue 

func (*FindLastMatchingRecordingRequest) CorrelationIdMaxValue() int64

func (*FindLastMatchingRecordingRequest) CorrelationIdMetaAttribute 

func (*FindLastMatchingRecordingRequest) CorrelationIdMetaAttribute(meta int) string

func (*FindLastMatchingRecordingRequest) CorrelationIdMinValue 

func (*FindLastMatchingRecordingRequest) CorrelationIdMinValue() int64

func (*FindLastMatchingRecordingRequest) CorrelationIdNullValue 

func (*FindLastMatchingRecordingRequest) CorrelationIdNullValue() int64

func (*FindLastMatchingRecordingRequest) CorrelationIdSinceVersion 

func (*FindLastMatchingRecordingRequest) CorrelationIdSinceVersion() uint16

func (*FindLastMatchingRecordingRequest) Decode 

func (f *FindLastMatchingRecordingRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*FindLastMatchingRecordingRequest) Encode 

func (f *FindLastMatchingRecordingRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*FindLastMatchingRecordingRequest) MinRecordingIdDeprecated 

func (*FindLastMatchingRecordingRequest) MinRecordingIdDeprecated() uint16

func (*FindLastMatchingRecordingRequest) MinRecordingIdId 

func (*FindLastMatchingRecordingRequest) MinRecordingIdId() uint16

func (*FindLastMatchingRecordingRequest) MinRecordingIdInActingVersion 

func (f *FindLastMatchingRecordingRequest) MinRecordingIdInActingVersion(actingVersion uint16) bool

func (*FindLastMatchingRecordingRequest) MinRecordingIdMaxValue 

func (*FindLastMatchingRecordingRequest) MinRecordingIdMaxValue() int64

func (*FindLastMatchingRecordingRequest) MinRecordingIdMetaAttribute 

func (*FindLastMatchingRecordingRequest) MinRecordingIdMetaAttribute(meta int) string

func (*FindLastMatchingRecordingRequest) MinRecordingIdMinValue 

func (*FindLastMatchingRecordingRequest) MinRecordingIdMinValue() int64

func (*FindLastMatchingRecordingRequest) MinRecordingIdNullValue 

func (*FindLastMatchingRecordingRequest) MinRecordingIdNullValue() int64

func (*FindLastMatchingRecordingRequest) MinRecordingIdSinceVersion 

func (*FindLastMatchingRecordingRequest) MinRecordingIdSinceVersion() uint16

func (*FindLastMatchingRecordingRequest) RangeCheck 

func (f *FindLastMatchingRecordingRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*FindLastMatchingRecordingRequest) SbeBlockLength 

func (*FindLastMatchingRecordingRequest) SbeBlockLength() (blockLength uint16)

func (*FindLastMatchingRecordingRequest) SbeSchemaId 

func (*FindLastMatchingRecordingRequest) SbeSchemaId() (schemaId uint16)

func (*FindLastMatchingRecordingRequest) SbeSchemaVersion 

func (*FindLastMatchingRecordingRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*FindLastMatchingRecordingRequest) SbeSemanticType 

func (*FindLastMatchingRecordingRequest) SbeSemanticType() (semanticType []byte)

func (*FindLastMatchingRecordingRequest) SbeTemplateId 

func (*FindLastMatchingRecordingRequest) SbeTemplateId() (templateId uint16)

func (*FindLastMatchingRecordingRequest) SessionIdDeprecated 

func (*FindLastMatchingRecordingRequest) SessionIdDeprecated() uint16

func (*FindLastMatchingRecordingRequest) SessionIdId 

func (*FindLastMatchingRecordingRequest) SessionIdId() uint16

func (*FindLastMatchingRecordingRequest) SessionIdInActingVersion 

func (f *FindLastMatchingRecordingRequest) SessionIdInActingVersion(actingVersion uint16) bool

func (*FindLastMatchingRecordingRequest) SessionIdMaxValue 

func (*FindLastMatchingRecordingRequest) SessionIdMaxValue() int32

func (*FindLastMatchingRecordingRequest) SessionIdMetaAttribute 

func (*FindLastMatchingRecordingRequest) SessionIdMetaAttribute(meta int) string

func (*FindLastMatchingRecordingRequest) SessionIdMinValue 

func (*FindLastMatchingRecordingRequest) SessionIdMinValue() int32

func (*FindLastMatchingRecordingRequest) SessionIdNullValue 

func (*FindLastMatchingRecordingRequest) SessionIdNullValue() int32

func (*FindLastMatchingRecordingRequest) SessionIdSinceVersion 

func (*FindLastMatchingRecordingRequest) SessionIdSinceVersion() uint16

func (*FindLastMatchingRecordingRequest) StreamIdDeprecated 

func (*FindLastMatchingRecordingRequest) StreamIdDeprecated() uint16

func (*FindLastMatchingRecordingRequest) StreamIdId 

func (*FindLastMatchingRecordingRequest) StreamIdId() uint16

func (*FindLastMatchingRecordingRequest) StreamIdInActingVersion 

func (f *FindLastMatchingRecordingRequest) StreamIdInActingVersion(actingVersion uint16) bool

func (*FindLastMatchingRecordingRequest) StreamIdMaxValue 

func (*FindLastMatchingRecordingRequest) StreamIdMaxValue() int32

func (*FindLastMatchingRecordingRequest) StreamIdMetaAttribute 

func (*FindLastMatchingRecordingRequest) StreamIdMetaAttribute(meta int) string

func (*FindLastMatchingRecordingRequest) StreamIdMinValue 

func (*FindLastMatchingRecordingRequest) StreamIdMinValue() int32

func (*FindLastMatchingRecordingRequest) StreamIdNullValue 

func (*FindLastMatchingRecordingRequest) StreamIdNullValue() int32

func (*FindLastMatchingRecordingRequest) StreamIdSinceVersion 

func (*FindLastMatchingRecordingRequest) StreamIdSinceVersion() uint16

type KeepAliveRequest 

type KeepAliveRequest struct {
	ControlSessionId int64
	CorrelationId    int64
}

func (*KeepAliveRequest) ControlSessionIdDeprecated 

func (*KeepAliveRequest) ControlSessionIdDeprecated() uint16

func (*KeepAliveRequest) ControlSessionIdId 

func (*KeepAliveRequest) ControlSessionIdId() uint16

func (*KeepAliveRequest) ControlSessionIdInActingVersion 

func (k *KeepAliveRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*KeepAliveRequest) ControlSessionIdMaxValue 

func (*KeepAliveRequest) ControlSessionIdMaxValue() int64

func (*KeepAliveRequest) ControlSessionIdMetaAttribute 

func (*KeepAliveRequest) ControlSessionIdMetaAttribute(meta int) string

func (*KeepAliveRequest) ControlSessionIdMinValue 

func (*KeepAliveRequest) ControlSessionIdMinValue() int64

func (*KeepAliveRequest) ControlSessionIdNullValue 

func (*KeepAliveRequest) ControlSessionIdNullValue() int64

func (*KeepAliveRequest) ControlSessionIdSinceVersion 

func (*KeepAliveRequest) ControlSessionIdSinceVersion() uint16

func (*KeepAliveRequest) CorrelationIdDeprecated 

func (*KeepAliveRequest) CorrelationIdDeprecated() uint16

func (*KeepAliveRequest) CorrelationIdId 

func (*KeepAliveRequest) CorrelationIdId() uint16

func (*KeepAliveRequest) CorrelationIdInActingVersion 

func (k *KeepAliveRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*KeepAliveRequest) CorrelationIdMaxValue 

func (*KeepAliveRequest) CorrelationIdMaxValue() int64

func (*KeepAliveRequest) CorrelationIdMetaAttribute 

func (*KeepAliveRequest) CorrelationIdMetaAttribute(meta int) string

func (*KeepAliveRequest) CorrelationIdMinValue 

func (*KeepAliveRequest) CorrelationIdMinValue() int64

func (*KeepAliveRequest) CorrelationIdNullValue 

func (*KeepAliveRequest) CorrelationIdNullValue() int64

func (*KeepAliveRequest) CorrelationIdSinceVersion 

func (*KeepAliveRequest) CorrelationIdSinceVersion() uint16

func (*KeepAliveRequest) Decode 

func (k *KeepAliveRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*KeepAliveRequest) Encode 

func (k *KeepAliveRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*KeepAliveRequest) RangeCheck 

func (k *KeepAliveRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*KeepAliveRequest) SbeBlockLength 

func (*KeepAliveRequest) SbeBlockLength() (blockLength uint16)

func (*KeepAliveRequest) SbeSchemaId 

func (*KeepAliveRequest) SbeSchemaId() (schemaId uint16)

func (*KeepAliveRequest) SbeSchemaVersion 

func (*KeepAliveRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*KeepAliveRequest) SbeSemanticType 

func (*KeepAliveRequest) SbeSemanticType() (semanticType []byte)

func (*KeepAliveRequest) SbeTemplateId 

func (*KeepAliveRequest) SbeTemplateId() (templateId uint16)

type ListRecordingRequest 

type ListRecordingRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
}

func (*ListRecordingRequest) ControlSessionIdDeprecated 

func (*ListRecordingRequest) ControlSessionIdDeprecated() uint16

func (*ListRecordingRequest) ControlSessionIdId 

func (*ListRecordingRequest) ControlSessionIdId() uint16

func (*ListRecordingRequest) ControlSessionIdInActingVersion 

func (l *ListRecordingRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingRequest) ControlSessionIdMaxValue 

func (*ListRecordingRequest) ControlSessionIdMaxValue() int64

func (*ListRecordingRequest) ControlSessionIdMetaAttribute 

func (*ListRecordingRequest) ControlSessionIdMetaAttribute(meta int) string

func (*ListRecordingRequest) ControlSessionIdMinValue 

func (*ListRecordingRequest) ControlSessionIdMinValue() int64

func (*ListRecordingRequest) ControlSessionIdNullValue 

func (*ListRecordingRequest) ControlSessionIdNullValue() int64

func (*ListRecordingRequest) ControlSessionIdSinceVersion 

func (*ListRecordingRequest) ControlSessionIdSinceVersion() uint16

func (*ListRecordingRequest) CorrelationIdDeprecated 

func (*ListRecordingRequest) CorrelationIdDeprecated() uint16

func (*ListRecordingRequest) CorrelationIdId 

func (*ListRecordingRequest) CorrelationIdId() uint16

func (*ListRecordingRequest) CorrelationIdInActingVersion 

func (l *ListRecordingRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingRequest) CorrelationIdMaxValue 

func (*ListRecordingRequest) CorrelationIdMaxValue() int64

func (*ListRecordingRequest) CorrelationIdMetaAttribute 

func (*ListRecordingRequest) CorrelationIdMetaAttribute(meta int) string

func (*ListRecordingRequest) CorrelationIdMinValue 

func (*ListRecordingRequest) CorrelationIdMinValue() int64

func (*ListRecordingRequest) CorrelationIdNullValue 

func (*ListRecordingRequest) CorrelationIdNullValue() int64

func (*ListRecordingRequest) CorrelationIdSinceVersion 

func (*ListRecordingRequest) CorrelationIdSinceVersion() uint16

func (*ListRecordingRequest) Decode 

func (l *ListRecordingRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ListRecordingRequest) Encode 

func (l *ListRecordingRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*ListRecordingRequest) RangeCheck 

func (l *ListRecordingRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ListRecordingRequest) RecordingIdDeprecated 

func (*ListRecordingRequest) RecordingIdDeprecated() uint16

func (*ListRecordingRequest) RecordingIdId 

func (*ListRecordingRequest) RecordingIdId() uint16

func (*ListRecordingRequest) RecordingIdInActingVersion 

func (l *ListRecordingRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingRequest) RecordingIdMaxValue 

func (*ListRecordingRequest) RecordingIdMaxValue() int64

func (*ListRecordingRequest) RecordingIdMetaAttribute 

func (*ListRecordingRequest) RecordingIdMetaAttribute(meta int) string

func (*ListRecordingRequest) RecordingIdMinValue 

func (*ListRecordingRequest) RecordingIdMinValue() int64

func (*ListRecordingRequest) RecordingIdNullValue 

func (*ListRecordingRequest) RecordingIdNullValue() int64

func (*ListRecordingRequest) RecordingIdSinceVersion 

func (*ListRecordingRequest) RecordingIdSinceVersion() uint16

func (*ListRecordingRequest) SbeBlockLength 

func (*ListRecordingRequest) SbeBlockLength() (blockLength uint16)

func (*ListRecordingRequest) SbeSchemaId 

func (*ListRecordingRequest) SbeSchemaId() (schemaId uint16)

func (*ListRecordingRequest) SbeSchemaVersion 

func (*ListRecordingRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*ListRecordingRequest) SbeSemanticType 

func (*ListRecordingRequest) SbeSemanticType() (semanticType []byte)

func (*ListRecordingRequest) SbeTemplateId 

func (*ListRecordingRequest) SbeTemplateId() (templateId uint16)

type ListRecordingSubscriptionsRequest 

type ListRecordingSubscriptionsRequest struct {
	ControlSessionId  int64
	CorrelationId     int64
	PseudoIndex       int32
	SubscriptionCount int32
	ApplyStreamId     BooleanTypeEnum
	StreamId          int32
	Channel           []uint8
}

func (*ListRecordingSubscriptionsRequest) ApplyStreamIdDeprecated 

func (*ListRecordingSubscriptionsRequest) ApplyStreamIdDeprecated() uint16

func (*ListRecordingSubscriptionsRequest) ApplyStreamIdId 

func (*ListRecordingSubscriptionsRequest) ApplyStreamIdId() uint16

func (*ListRecordingSubscriptionsRequest) ApplyStreamIdInActingVersion 

func (l *ListRecordingSubscriptionsRequest) ApplyStreamIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingSubscriptionsRequest) ApplyStreamIdMetaAttribute 

func (*ListRecordingSubscriptionsRequest) ApplyStreamIdMetaAttribute(meta int) string

func (*ListRecordingSubscriptionsRequest) ApplyStreamIdSinceVersion 

func (*ListRecordingSubscriptionsRequest) ApplyStreamIdSinceVersion() uint16

func (ListRecordingSubscriptionsRequest) ChannelCharacterEncoding 

func (ListRecordingSubscriptionsRequest) ChannelCharacterEncoding() string

func (*ListRecordingSubscriptionsRequest) ChannelDeprecated 

func (*ListRecordingSubscriptionsRequest) ChannelDeprecated() uint16

func (ListRecordingSubscriptionsRequest) ChannelHeaderLength 

func (ListRecordingSubscriptionsRequest) ChannelHeaderLength() uint64

func (*ListRecordingSubscriptionsRequest) ChannelInActingVersion 

func (l *ListRecordingSubscriptionsRequest) ChannelInActingVersion(actingVersion uint16) bool

func (*ListRecordingSubscriptionsRequest) ChannelMetaAttribute 

func (*ListRecordingSubscriptionsRequest) ChannelMetaAttribute(meta int) string

func (*ListRecordingSubscriptionsRequest) ChannelSinceVersion 

func (*ListRecordingSubscriptionsRequest) ChannelSinceVersion() uint16

func (*ListRecordingSubscriptionsRequest) ControlSessionIdDeprecated 

func (*ListRecordingSubscriptionsRequest) ControlSessionIdDeprecated() uint16

func (*ListRecordingSubscriptionsRequest) ControlSessionIdId 

func (*ListRecordingSubscriptionsRequest) ControlSessionIdId() uint16

func (*ListRecordingSubscriptionsRequest) ControlSessionIdInActingVersion 

func (l *ListRecordingSubscriptionsRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingSubscriptionsRequest) ControlSessionIdMaxValue 

func (*ListRecordingSubscriptionsRequest) ControlSessionIdMaxValue() int64

func (*ListRecordingSubscriptionsRequest) ControlSessionIdMetaAttribute 

func (*ListRecordingSubscriptionsRequest) ControlSessionIdMetaAttribute(meta int) string

func (*ListRecordingSubscriptionsRequest) ControlSessionIdMinValue 

func (*ListRecordingSubscriptionsRequest) ControlSessionIdMinValue() int64

func (*ListRecordingSubscriptionsRequest) ControlSessionIdNullValue 

func (*ListRecordingSubscriptionsRequest) ControlSessionIdNullValue() int64

func (*ListRecordingSubscriptionsRequest) ControlSessionIdSinceVersion 

func (*ListRecordingSubscriptionsRequest) ControlSessionIdSinceVersion() uint16

func (*ListRecordingSubscriptionsRequest) CorrelationIdDeprecated 

func (*ListRecordingSubscriptionsRequest) CorrelationIdDeprecated() uint16

func (*ListRecordingSubscriptionsRequest) CorrelationIdId 

func (*ListRecordingSubscriptionsRequest) CorrelationIdId() uint16

func (*ListRecordingSubscriptionsRequest) CorrelationIdInActingVersion 

func (l *ListRecordingSubscriptionsRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingSubscriptionsRequest) CorrelationIdMaxValue 

func (*ListRecordingSubscriptionsRequest) CorrelationIdMaxValue() int64

func (*ListRecordingSubscriptionsRequest) CorrelationIdMetaAttribute 

func (*ListRecordingSubscriptionsRequest) CorrelationIdMetaAttribute(meta int) string

func (*ListRecordingSubscriptionsRequest) CorrelationIdMinValue 

func (*ListRecordingSubscriptionsRequest) CorrelationIdMinValue() int64

func (*ListRecordingSubscriptionsRequest) CorrelationIdNullValue 

func (*ListRecordingSubscriptionsRequest) CorrelationIdNullValue() int64

func (*ListRecordingSubscriptionsRequest) CorrelationIdSinceVersion 

func (*ListRecordingSubscriptionsRequest) CorrelationIdSinceVersion() uint16

func (*ListRecordingSubscriptionsRequest) Decode 

func (l *ListRecordingSubscriptionsRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ListRecordingSubscriptionsRequest) Encode 

func (l *ListRecordingSubscriptionsRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*ListRecordingSubscriptionsRequest) PseudoIndexDeprecated 

func (*ListRecordingSubscriptionsRequest) PseudoIndexDeprecated() uint16

func (*ListRecordingSubscriptionsRequest) PseudoIndexId 

func (*ListRecordingSubscriptionsRequest) PseudoIndexId() uint16

func (*ListRecordingSubscriptionsRequest) PseudoIndexInActingVersion 

func (l *ListRecordingSubscriptionsRequest) PseudoIndexInActingVersion(actingVersion uint16) bool

func (*ListRecordingSubscriptionsRequest) PseudoIndexMaxValue 

func (*ListRecordingSubscriptionsRequest) PseudoIndexMaxValue() int32

func (*ListRecordingSubscriptionsRequest) PseudoIndexMetaAttribute 

func (*ListRecordingSubscriptionsRequest) PseudoIndexMetaAttribute(meta int) string

func (*ListRecordingSubscriptionsRequest) PseudoIndexMinValue 

func (*ListRecordingSubscriptionsRequest) PseudoIndexMinValue() int32

func (*ListRecordingSubscriptionsRequest) PseudoIndexNullValue 

func (*ListRecordingSubscriptionsRequest) PseudoIndexNullValue() int32

func (*ListRecordingSubscriptionsRequest) PseudoIndexSinceVersion 

func (*ListRecordingSubscriptionsRequest) PseudoIndexSinceVersion() uint16

func (*ListRecordingSubscriptionsRequest) RangeCheck 

func (l *ListRecordingSubscriptionsRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ListRecordingSubscriptionsRequest) SbeBlockLength 

func (*ListRecordingSubscriptionsRequest) SbeBlockLength() (blockLength uint16)

func (*ListRecordingSubscriptionsRequest) SbeSchemaId 

func (*ListRecordingSubscriptionsRequest) SbeSchemaId() (schemaId uint16)

func (*ListRecordingSubscriptionsRequest) SbeSchemaVersion 

func (*ListRecordingSubscriptionsRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*ListRecordingSubscriptionsRequest) SbeSemanticType 

func (*ListRecordingSubscriptionsRequest) SbeSemanticType() (semanticType []byte)

func (*ListRecordingSubscriptionsRequest) SbeTemplateId 

func (*ListRecordingSubscriptionsRequest) SbeTemplateId() (templateId uint16)

func (*ListRecordingSubscriptionsRequest) StreamIdDeprecated 

func (*ListRecordingSubscriptionsRequest) StreamIdDeprecated() uint16

func (*ListRecordingSubscriptionsRequest) StreamIdId 

func (*ListRecordingSubscriptionsRequest) StreamIdId() uint16

func (*ListRecordingSubscriptionsRequest) StreamIdInActingVersion 

func (l *ListRecordingSubscriptionsRequest) StreamIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingSubscriptionsRequest) StreamIdMaxValue 

func (*ListRecordingSubscriptionsRequest) StreamIdMaxValue() int32

func (*ListRecordingSubscriptionsRequest) StreamIdMetaAttribute 

func (*ListRecordingSubscriptionsRequest) StreamIdMetaAttribute(meta int) string

func (*ListRecordingSubscriptionsRequest) StreamIdMinValue 

func (*ListRecordingSubscriptionsRequest) StreamIdMinValue() int32

func (*ListRecordingSubscriptionsRequest) StreamIdNullValue 

func (*ListRecordingSubscriptionsRequest) StreamIdNullValue() int32

func (*ListRecordingSubscriptionsRequest) StreamIdSinceVersion 

func (*ListRecordingSubscriptionsRequest) StreamIdSinceVersion() uint16

func (*ListRecordingSubscriptionsRequest) SubscriptionCountDeprecated 

func (*ListRecordingSubscriptionsRequest) SubscriptionCountDeprecated() uint16

func (*ListRecordingSubscriptionsRequest) SubscriptionCountId 

func (*ListRecordingSubscriptionsRequest) SubscriptionCountId() uint16

func (*ListRecordingSubscriptionsRequest) SubscriptionCountInActingVersion 

func (l *ListRecordingSubscriptionsRequest) SubscriptionCountInActingVersion(actingVersion uint16) bool

func (*ListRecordingSubscriptionsRequest) SubscriptionCountMaxValue 

func (*ListRecordingSubscriptionsRequest) SubscriptionCountMaxValue() int32

func (*ListRecordingSubscriptionsRequest) SubscriptionCountMetaAttribute 

func (*ListRecordingSubscriptionsRequest) SubscriptionCountMetaAttribute(meta int) string

func (*ListRecordingSubscriptionsRequest) SubscriptionCountMinValue 

func (*ListRecordingSubscriptionsRequest) SubscriptionCountMinValue() int32

func (*ListRecordingSubscriptionsRequest) SubscriptionCountNullValue 

func (*ListRecordingSubscriptionsRequest) SubscriptionCountNullValue() int32

func (*ListRecordingSubscriptionsRequest) SubscriptionCountSinceVersion 

func (*ListRecordingSubscriptionsRequest) SubscriptionCountSinceVersion() uint16

type ListRecordingsForUriRequest 

type ListRecordingsForUriRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	FromRecordingId  int64
	RecordCount      int32
	StreamId         int32
	Channel          []uint8
}

func (ListRecordingsForUriRequest) ChannelCharacterEncoding 

func (ListRecordingsForUriRequest) ChannelCharacterEncoding() string

func (*ListRecordingsForUriRequest) ChannelDeprecated 

func (*ListRecordingsForUriRequest) ChannelDeprecated() uint16

func (ListRecordingsForUriRequest) ChannelHeaderLength 

func (ListRecordingsForUriRequest) ChannelHeaderLength() uint64

func (*ListRecordingsForUriRequest) ChannelInActingVersion 

func (l *ListRecordingsForUriRequest) ChannelInActingVersion(actingVersion uint16) bool

func (*ListRecordingsForUriRequest) ChannelMetaAttribute 

func (*ListRecordingsForUriRequest) ChannelMetaAttribute(meta int) string

func (*ListRecordingsForUriRequest) ChannelSinceVersion 

func (*ListRecordingsForUriRequest) ChannelSinceVersion() uint16

func (*ListRecordingsForUriRequest) ControlSessionIdDeprecated 

func (*ListRecordingsForUriRequest) ControlSessionIdDeprecated() uint16

func (*ListRecordingsForUriRequest) ControlSessionIdId 

func (*ListRecordingsForUriRequest) ControlSessionIdId() uint16

func (*ListRecordingsForUriRequest) ControlSessionIdInActingVersion 

func (l *ListRecordingsForUriRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingsForUriRequest) ControlSessionIdMaxValue 

func (*ListRecordingsForUriRequest) ControlSessionIdMaxValue() int64

func (*ListRecordingsForUriRequest) ControlSessionIdMetaAttribute 

func (*ListRecordingsForUriRequest) ControlSessionIdMetaAttribute(meta int) string

func (*ListRecordingsForUriRequest) ControlSessionIdMinValue 

func (*ListRecordingsForUriRequest) ControlSessionIdMinValue() int64

func (*ListRecordingsForUriRequest) ControlSessionIdNullValue 

func (*ListRecordingsForUriRequest) ControlSessionIdNullValue() int64

func (*ListRecordingsForUriRequest) ControlSessionIdSinceVersion 

func (*ListRecordingsForUriRequest) ControlSessionIdSinceVersion() uint16

func (*ListRecordingsForUriRequest) CorrelationIdDeprecated 

func (*ListRecordingsForUriRequest) CorrelationIdDeprecated() uint16

func (*ListRecordingsForUriRequest) CorrelationIdId 

func (*ListRecordingsForUriRequest) CorrelationIdId() uint16

func (*ListRecordingsForUriRequest) CorrelationIdInActingVersion 

func (l *ListRecordingsForUriRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingsForUriRequest) CorrelationIdMaxValue 

func (*ListRecordingsForUriRequest) CorrelationIdMaxValue() int64

func (*ListRecordingsForUriRequest) CorrelationIdMetaAttribute 

func (*ListRecordingsForUriRequest) CorrelationIdMetaAttribute(meta int) string

func (*ListRecordingsForUriRequest) CorrelationIdMinValue 

func (*ListRecordingsForUriRequest) CorrelationIdMinValue() int64

func (*ListRecordingsForUriRequest) CorrelationIdNullValue 

func (*ListRecordingsForUriRequest) CorrelationIdNullValue() int64

func (*ListRecordingsForUriRequest) CorrelationIdSinceVersion 

func (*ListRecordingsForUriRequest) CorrelationIdSinceVersion() uint16

func (*ListRecordingsForUriRequest) Decode 

func (l *ListRecordingsForUriRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ListRecordingsForUriRequest) Encode 

func (l *ListRecordingsForUriRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*ListRecordingsForUriRequest) FromRecordingIdDeprecated 

func (*ListRecordingsForUriRequest) FromRecordingIdDeprecated() uint16

func (*ListRecordingsForUriRequest) FromRecordingIdId 

func (*ListRecordingsForUriRequest) FromRecordingIdId() uint16

func (*ListRecordingsForUriRequest) FromRecordingIdInActingVersion 

func (l *ListRecordingsForUriRequest) FromRecordingIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingsForUriRequest) FromRecordingIdMaxValue 

func (*ListRecordingsForUriRequest) FromRecordingIdMaxValue() int64

func (*ListRecordingsForUriRequest) FromRecordingIdMetaAttribute 

func (*ListRecordingsForUriRequest) FromRecordingIdMetaAttribute(meta int) string

func (*ListRecordingsForUriRequest) FromRecordingIdMinValue 

func (*ListRecordingsForUriRequest) FromRecordingIdMinValue() int64

func (*ListRecordingsForUriRequest) FromRecordingIdNullValue 

func (*ListRecordingsForUriRequest) FromRecordingIdNullValue() int64

func (*ListRecordingsForUriRequest) FromRecordingIdSinceVersion 

func (*ListRecordingsForUriRequest) FromRecordingIdSinceVersion() uint16

func (*ListRecordingsForUriRequest) RangeCheck 

func (l *ListRecordingsForUriRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ListRecordingsForUriRequest) RecordCountDeprecated 

func (*ListRecordingsForUriRequest) RecordCountDeprecated() uint16

func (*ListRecordingsForUriRequest) RecordCountId 

func (*ListRecordingsForUriRequest) RecordCountId() uint16

func (*ListRecordingsForUriRequest) RecordCountInActingVersion 

func (l *ListRecordingsForUriRequest) RecordCountInActingVersion(actingVersion uint16) bool

func (*ListRecordingsForUriRequest) RecordCountMaxValue 

func (*ListRecordingsForUriRequest) RecordCountMaxValue() int32

func (*ListRecordingsForUriRequest) RecordCountMetaAttribute 

func (*ListRecordingsForUriRequest) RecordCountMetaAttribute(meta int) string

func (*ListRecordingsForUriRequest) RecordCountMinValue 

func (*ListRecordingsForUriRequest) RecordCountMinValue() int32

func (*ListRecordingsForUriRequest) RecordCountNullValue 

func (*ListRecordingsForUriRequest) RecordCountNullValue() int32

func (*ListRecordingsForUriRequest) RecordCountSinceVersion 

func (*ListRecordingsForUriRequest) RecordCountSinceVersion() uint16

func (*ListRecordingsForUriRequest) SbeBlockLength 

func (*ListRecordingsForUriRequest) SbeBlockLength() (blockLength uint16)

func (*ListRecordingsForUriRequest) SbeSchemaId 

func (*ListRecordingsForUriRequest) SbeSchemaId() (schemaId uint16)

func (*ListRecordingsForUriRequest) SbeSchemaVersion 

func (*ListRecordingsForUriRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*ListRecordingsForUriRequest) SbeSemanticType 

func (*ListRecordingsForUriRequest) SbeSemanticType() (semanticType []byte)

func (*ListRecordingsForUriRequest) SbeTemplateId 

func (*ListRecordingsForUriRequest) SbeTemplateId() (templateId uint16)

func (*ListRecordingsForUriRequest) StreamIdDeprecated 

func (*ListRecordingsForUriRequest) StreamIdDeprecated() uint16

func (*ListRecordingsForUriRequest) StreamIdId 

func (*ListRecordingsForUriRequest) StreamIdId() uint16

func (*ListRecordingsForUriRequest) StreamIdInActingVersion 

func (l *ListRecordingsForUriRequest) StreamIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingsForUriRequest) StreamIdMaxValue 

func (*ListRecordingsForUriRequest) StreamIdMaxValue() int32

func (*ListRecordingsForUriRequest) StreamIdMetaAttribute 

func (*ListRecordingsForUriRequest) StreamIdMetaAttribute(meta int) string

func (*ListRecordingsForUriRequest) StreamIdMinValue 

func (*ListRecordingsForUriRequest) StreamIdMinValue() int32

func (*ListRecordingsForUriRequest) StreamIdNullValue 

func (*ListRecordingsForUriRequest) StreamIdNullValue() int32

func (*ListRecordingsForUriRequest) StreamIdSinceVersion 

func (*ListRecordingsForUriRequest) StreamIdSinceVersion() uint16

type ListRecordingsRequest 

type ListRecordingsRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	FromRecordingId  int64
	RecordCount      int32
}

func (*ListRecordingsRequest) ControlSessionIdDeprecated 

func (*ListRecordingsRequest) ControlSessionIdDeprecated() uint16

func (*ListRecordingsRequest) ControlSessionIdId 

func (*ListRecordingsRequest) ControlSessionIdId() uint16

func (*ListRecordingsRequest) ControlSessionIdInActingVersion 

func (l *ListRecordingsRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingsRequest) ControlSessionIdMaxValue 

func (*ListRecordingsRequest) ControlSessionIdMaxValue() int64

func (*ListRecordingsRequest) ControlSessionIdMetaAttribute 

func (*ListRecordingsRequest) ControlSessionIdMetaAttribute(meta int) string

func (*ListRecordingsRequest) ControlSessionIdMinValue 

func (*ListRecordingsRequest) ControlSessionIdMinValue() int64

func (*ListRecordingsRequest) ControlSessionIdNullValue 

func (*ListRecordingsRequest) ControlSessionIdNullValue() int64

func (*ListRecordingsRequest) ControlSessionIdSinceVersion 

func (*ListRecordingsRequest) ControlSessionIdSinceVersion() uint16

func (*ListRecordingsRequest) CorrelationIdDeprecated 

func (*ListRecordingsRequest) CorrelationIdDeprecated() uint16

func (*ListRecordingsRequest) CorrelationIdId 

func (*ListRecordingsRequest) CorrelationIdId() uint16

func (*ListRecordingsRequest) CorrelationIdInActingVersion 

func (l *ListRecordingsRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingsRequest) CorrelationIdMaxValue 

func (*ListRecordingsRequest) CorrelationIdMaxValue() int64

func (*ListRecordingsRequest) CorrelationIdMetaAttribute 

func (*ListRecordingsRequest) CorrelationIdMetaAttribute(meta int) string

func (*ListRecordingsRequest) CorrelationIdMinValue 

func (*ListRecordingsRequest) CorrelationIdMinValue() int64

func (*ListRecordingsRequest) CorrelationIdNullValue 

func (*ListRecordingsRequest) CorrelationIdNullValue() int64

func (*ListRecordingsRequest) CorrelationIdSinceVersion 

func (*ListRecordingsRequest) CorrelationIdSinceVersion() uint16

func (*ListRecordingsRequest) Decode 

func (l *ListRecordingsRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ListRecordingsRequest) Encode 

func (l *ListRecordingsRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*ListRecordingsRequest) FromRecordingIdDeprecated 

func (*ListRecordingsRequest) FromRecordingIdDeprecated() uint16

func (*ListRecordingsRequest) FromRecordingIdId 

func (*ListRecordingsRequest) FromRecordingIdId() uint16

func (*ListRecordingsRequest) FromRecordingIdInActingVersion 

func (l *ListRecordingsRequest) FromRecordingIdInActingVersion(actingVersion uint16) bool

func (*ListRecordingsRequest) FromRecordingIdMaxValue 

func (*ListRecordingsRequest) FromRecordingIdMaxValue() int64

func (*ListRecordingsRequest) FromRecordingIdMetaAttribute 

func (*ListRecordingsRequest) FromRecordingIdMetaAttribute(meta int) string

func (*ListRecordingsRequest) FromRecordingIdMinValue 

func (*ListRecordingsRequest) FromRecordingIdMinValue() int64

func (*ListRecordingsRequest) FromRecordingIdNullValue 

func (*ListRecordingsRequest) FromRecordingIdNullValue() int64

func (*ListRecordingsRequest) FromRecordingIdSinceVersion 

func (*ListRecordingsRequest) FromRecordingIdSinceVersion() uint16

func (*ListRecordingsRequest) RangeCheck 

func (l *ListRecordingsRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ListRecordingsRequest) RecordCountDeprecated 

func (*ListRecordingsRequest) RecordCountDeprecated() uint16

func (*ListRecordingsRequest) RecordCountId 

func (*ListRecordingsRequest) RecordCountId() uint16

func (*ListRecordingsRequest) RecordCountInActingVersion 

func (l *ListRecordingsRequest) RecordCountInActingVersion(actingVersion uint16) bool

func (*ListRecordingsRequest) RecordCountMaxValue 

func (*ListRecordingsRequest) RecordCountMaxValue() int32

func (*ListRecordingsRequest) RecordCountMetaAttribute 

func (*ListRecordingsRequest) RecordCountMetaAttribute(meta int) string

func (*ListRecordingsRequest) RecordCountMinValue 

func (*ListRecordingsRequest) RecordCountMinValue() int32

func (*ListRecordingsRequest) RecordCountNullValue 

func (*ListRecordingsRequest) RecordCountNullValue() int32

func (*ListRecordingsRequest) RecordCountSinceVersion 

func (*ListRecordingsRequest) RecordCountSinceVersion() uint16

func (*ListRecordingsRequest) SbeBlockLength 

func (*ListRecordingsRequest) SbeBlockLength() (blockLength uint16)

func (*ListRecordingsRequest) SbeSchemaId 

func (*ListRecordingsRequest) SbeSchemaId() (schemaId uint16)

func (*ListRecordingsRequest) SbeSchemaVersion 

func (*ListRecordingsRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*ListRecordingsRequest) SbeSemanticType 

func (*ListRecordingsRequest) SbeSemanticType() (semanticType []byte)

func (*ListRecordingsRequest) SbeTemplateId 

func (*ListRecordingsRequest) SbeTemplateId() (templateId uint16)

type MessageHeader 

type MessageHeader struct {
	BlockLength uint16
	TemplateId  uint16
	SchemaId    uint16
	Version     uint16
}

func (*MessageHeader) BlockLengthDeprecated 

func (*MessageHeader) BlockLengthDeprecated() uint16

func (*MessageHeader) BlockLengthInActingVersion 

func (m *MessageHeader) BlockLengthInActingVersion(actingVersion uint16) bool

func (*MessageHeader) BlockLengthMaxValue 

func (*MessageHeader) BlockLengthMaxValue() uint16

func (*MessageHeader) BlockLengthMinValue 

func (*MessageHeader) BlockLengthMinValue() uint16

func (*MessageHeader) BlockLengthNullValue 

func (*MessageHeader) BlockLengthNullValue() uint16

func (*MessageHeader) BlockLengthSinceVersion 

func (*MessageHeader) BlockLengthSinceVersion() uint16

func (*MessageHeader) Decode 

func (m *MessageHeader) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16) error

func (*MessageHeader) Encode 

func (m *MessageHeader) Encode(_m *SbeGoMarshaller, _w io.Writer) error

func (*MessageHeader) EncodedLength 

func (*MessageHeader) EncodedLength() int64

func (*MessageHeader) RangeCheck 

func (m *MessageHeader) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*MessageHeader) SchemaIdDeprecated 

func (*MessageHeader) SchemaIdDeprecated() uint16

func (*MessageHeader) SchemaIdInActingVersion 

func (m *MessageHeader) SchemaIdInActingVersion(actingVersion uint16) bool

func (*MessageHeader) SchemaIdMaxValue 

func (*MessageHeader) SchemaIdMaxValue() uint16

func (*MessageHeader) SchemaIdMinValue 

func (*MessageHeader) SchemaIdMinValue() uint16

func (*MessageHeader) SchemaIdNullValue 

func (*MessageHeader) SchemaIdNullValue() uint16

func (*MessageHeader) SchemaIdSinceVersion 

func (*MessageHeader) SchemaIdSinceVersion() uint16

func (*MessageHeader) TemplateIdDeprecated 

func (*MessageHeader) TemplateIdDeprecated() uint16

func (*MessageHeader) TemplateIdInActingVersion 

func (m *MessageHeader) TemplateIdInActingVersion(actingVersion uint16) bool

func (*MessageHeader) TemplateIdMaxValue 

func (*MessageHeader) TemplateIdMaxValue() uint16

func (*MessageHeader) TemplateIdMinValue 

func (*MessageHeader) TemplateIdMinValue() uint16

func (*MessageHeader) TemplateIdNullValue 

func (*MessageHeader) TemplateIdNullValue() uint16

func (*MessageHeader) TemplateIdSinceVersion 

func (*MessageHeader) TemplateIdSinceVersion() uint16

func (*MessageHeader) VersionDeprecated 

func (*MessageHeader) VersionDeprecated() uint16

func (*MessageHeader) VersionInActingVersion 

func (m *MessageHeader) VersionInActingVersion(actingVersion uint16) bool

func (*MessageHeader) VersionMaxValue 

func (*MessageHeader) VersionMaxValue() uint16

func (*MessageHeader) VersionMinValue 

func (*MessageHeader) VersionMinValue() uint16

func (*MessageHeader) VersionNullValue 

func (*MessageHeader) VersionNullValue() uint16

func (*MessageHeader) VersionSinceVersion 

func (*MessageHeader) VersionSinceVersion() uint16

type MigrateSegmentsRequest 

type MigrateSegmentsRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	SrcRecordingId   int64
	DstRecordingId   int64
}

func (*MigrateSegmentsRequest) ControlSessionIdDeprecated 

func (*MigrateSegmentsRequest) ControlSessionIdDeprecated() uint16

func (*MigrateSegmentsRequest) ControlSessionIdId 

func (*MigrateSegmentsRequest) ControlSessionIdId() uint16

func (*MigrateSegmentsRequest) ControlSessionIdInActingVersion 

func (m *MigrateSegmentsRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*MigrateSegmentsRequest) ControlSessionIdMaxValue 

func (*MigrateSegmentsRequest) ControlSessionIdMaxValue() int64

func (*MigrateSegmentsRequest) ControlSessionIdMetaAttribute 

func (*MigrateSegmentsRequest) ControlSessionIdMetaAttribute(meta int) string

func (*MigrateSegmentsRequest) ControlSessionIdMinValue 

func (*MigrateSegmentsRequest) ControlSessionIdMinValue() int64

func (*MigrateSegmentsRequest) ControlSessionIdNullValue 

func (*MigrateSegmentsRequest) ControlSessionIdNullValue() int64

func (*MigrateSegmentsRequest) ControlSessionIdSinceVersion 

func (*MigrateSegmentsRequest) ControlSessionIdSinceVersion() uint16

func (*MigrateSegmentsRequest) CorrelationIdDeprecated 

func (*MigrateSegmentsRequest) CorrelationIdDeprecated() uint16

func (*MigrateSegmentsRequest) CorrelationIdId 

func (*MigrateSegmentsRequest) CorrelationIdId() uint16

func (*MigrateSegmentsRequest) CorrelationIdInActingVersion 

func (m *MigrateSegmentsRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*MigrateSegmentsRequest) CorrelationIdMaxValue 

func (*MigrateSegmentsRequest) CorrelationIdMaxValue() int64

func (*MigrateSegmentsRequest) CorrelationIdMetaAttribute 

func (*MigrateSegmentsRequest) CorrelationIdMetaAttribute(meta int) string

func (*MigrateSegmentsRequest) CorrelationIdMinValue 

func (*MigrateSegmentsRequest) CorrelationIdMinValue() int64

func (*MigrateSegmentsRequest) CorrelationIdNullValue 

func (*MigrateSegmentsRequest) CorrelationIdNullValue() int64

func (*MigrateSegmentsRequest) CorrelationIdSinceVersion 

func (*MigrateSegmentsRequest) CorrelationIdSinceVersion() uint16

func (*MigrateSegmentsRequest) Decode 

func (m *MigrateSegmentsRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*MigrateSegmentsRequest) DstRecordingIdDeprecated 

func (*MigrateSegmentsRequest) DstRecordingIdDeprecated() uint16

func (*MigrateSegmentsRequest) DstRecordingIdId 

func (*MigrateSegmentsRequest) DstRecordingIdId() uint16

func (*MigrateSegmentsRequest) DstRecordingIdInActingVersion 

func (m *MigrateSegmentsRequest) DstRecordingIdInActingVersion(actingVersion uint16) bool

func (*MigrateSegmentsRequest) DstRecordingIdMaxValue 

func (*MigrateSegmentsRequest) DstRecordingIdMaxValue() int64

func (*MigrateSegmentsRequest) DstRecordingIdMetaAttribute 

func (*MigrateSegmentsRequest) DstRecordingIdMetaAttribute(meta int) string

func (*MigrateSegmentsRequest) DstRecordingIdMinValue 

func (*MigrateSegmentsRequest) DstRecordingIdMinValue() int64

func (*MigrateSegmentsRequest) DstRecordingIdNullValue 

func (*MigrateSegmentsRequest) DstRecordingIdNullValue() int64

func (*MigrateSegmentsRequest) DstRecordingIdSinceVersion 

func (*MigrateSegmentsRequest) DstRecordingIdSinceVersion() uint16

func (*MigrateSegmentsRequest) Encode 

func (m *MigrateSegmentsRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*MigrateSegmentsRequest) RangeCheck 

func (m *MigrateSegmentsRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*MigrateSegmentsRequest) SbeBlockLength 

func (*MigrateSegmentsRequest) SbeBlockLength() (blockLength uint16)

func (*MigrateSegmentsRequest) SbeSchemaId 

func (*MigrateSegmentsRequest) SbeSchemaId() (schemaId uint16)

func (*MigrateSegmentsRequest) SbeSchemaVersion 

func (*MigrateSegmentsRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*MigrateSegmentsRequest) SbeSemanticType 

func (*MigrateSegmentsRequest) SbeSemanticType() (semanticType []byte)

func (*MigrateSegmentsRequest) SbeTemplateId 

func (*MigrateSegmentsRequest) SbeTemplateId() (templateId uint16)

func (*MigrateSegmentsRequest) SrcRecordingIdDeprecated 

func (*MigrateSegmentsRequest) SrcRecordingIdDeprecated() uint16

func (*MigrateSegmentsRequest) SrcRecordingIdId 

func (*MigrateSegmentsRequest) SrcRecordingIdId() uint16

func (*MigrateSegmentsRequest) SrcRecordingIdInActingVersion 

func (m *MigrateSegmentsRequest) SrcRecordingIdInActingVersion(actingVersion uint16) bool

func (*MigrateSegmentsRequest) SrcRecordingIdMaxValue 

func (*MigrateSegmentsRequest) SrcRecordingIdMaxValue() int64

func (*MigrateSegmentsRequest) SrcRecordingIdMetaAttribute 

func (*MigrateSegmentsRequest) SrcRecordingIdMetaAttribute(meta int) string

func (*MigrateSegmentsRequest) SrcRecordingIdMinValue 

func (*MigrateSegmentsRequest) SrcRecordingIdMinValue() int64

func (*MigrateSegmentsRequest) SrcRecordingIdNullValue 

func (*MigrateSegmentsRequest) SrcRecordingIdNullValue() int64

func (*MigrateSegmentsRequest) SrcRecordingIdSinceVersion 

func (*MigrateSegmentsRequest) SrcRecordingIdSinceVersion() uint16

type PurgeRecordingRequest 

type PurgeRecordingRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
}

func (*PurgeRecordingRequest) ControlSessionIdDeprecated 

func (*PurgeRecordingRequest) ControlSessionIdDeprecated() uint16

func (*PurgeRecordingRequest) ControlSessionIdId 

func (*PurgeRecordingRequest) ControlSessionIdId() uint16

func (*PurgeRecordingRequest) ControlSessionIdInActingVersion 

func (p *PurgeRecordingRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*PurgeRecordingRequest) ControlSessionIdMaxValue 

func (*PurgeRecordingRequest) ControlSessionIdMaxValue() int64

func (*PurgeRecordingRequest) ControlSessionIdMetaAttribute 

func (*PurgeRecordingRequest) ControlSessionIdMetaAttribute(meta int) string

func (*PurgeRecordingRequest) ControlSessionIdMinValue 

func (*PurgeRecordingRequest) ControlSessionIdMinValue() int64

func (*PurgeRecordingRequest) ControlSessionIdNullValue 

func (*PurgeRecordingRequest) ControlSessionIdNullValue() int64

func (*PurgeRecordingRequest) ControlSessionIdSinceVersion 

func (*PurgeRecordingRequest) ControlSessionIdSinceVersion() uint16

func (*PurgeRecordingRequest) CorrelationIdDeprecated 

func (*PurgeRecordingRequest) CorrelationIdDeprecated() uint16

func (*PurgeRecordingRequest) CorrelationIdId 

func (*PurgeRecordingRequest) CorrelationIdId() uint16

func (*PurgeRecordingRequest) CorrelationIdInActingVersion 

func (p *PurgeRecordingRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*PurgeRecordingRequest) CorrelationIdMaxValue 

func (*PurgeRecordingRequest) CorrelationIdMaxValue() int64

func (*PurgeRecordingRequest) CorrelationIdMetaAttribute 

func (*PurgeRecordingRequest) CorrelationIdMetaAttribute(meta int) string

func (*PurgeRecordingRequest) CorrelationIdMinValue 

func (*PurgeRecordingRequest) CorrelationIdMinValue() int64

func (*PurgeRecordingRequest) CorrelationIdNullValue 

func (*PurgeRecordingRequest) CorrelationIdNullValue() int64

func (*PurgeRecordingRequest) CorrelationIdSinceVersion 

func (*PurgeRecordingRequest) CorrelationIdSinceVersion() uint16

func (*PurgeRecordingRequest) Decode 

func (p *PurgeRecordingRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*PurgeRecordingRequest) Encode 

func (p *PurgeRecordingRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*PurgeRecordingRequest) RangeCheck 

func (p *PurgeRecordingRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*PurgeRecordingRequest) RecordingIdDeprecated 

func (*PurgeRecordingRequest) RecordingIdDeprecated() uint16

func (*PurgeRecordingRequest) RecordingIdId 

func (*PurgeRecordingRequest) RecordingIdId() uint16

func (*PurgeRecordingRequest) RecordingIdInActingVersion 

func (p *PurgeRecordingRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*PurgeRecordingRequest) RecordingIdMaxValue 

func (*PurgeRecordingRequest) RecordingIdMaxValue() int64

func (*PurgeRecordingRequest) RecordingIdMetaAttribute 

func (*PurgeRecordingRequest) RecordingIdMetaAttribute(meta int) string

func (*PurgeRecordingRequest) RecordingIdMinValue 

func (*PurgeRecordingRequest) RecordingIdMinValue() int64

func (*PurgeRecordingRequest) RecordingIdNullValue 

func (*PurgeRecordingRequest) RecordingIdNullValue() int64

func (*PurgeRecordingRequest) RecordingIdSinceVersion 

func (*PurgeRecordingRequest) RecordingIdSinceVersion() uint16

func (*PurgeRecordingRequest) SbeBlockLength 

func (*PurgeRecordingRequest) SbeBlockLength() (blockLength uint16)

func (*PurgeRecordingRequest) SbeSchemaId 

func (*PurgeRecordingRequest) SbeSchemaId() (schemaId uint16)

func (*PurgeRecordingRequest) SbeSchemaVersion 

func (*PurgeRecordingRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*PurgeRecordingRequest) SbeSemanticType 

func (*PurgeRecordingRequest) SbeSemanticType() (semanticType []byte)

func (*PurgeRecordingRequest) SbeTemplateId 

func (*PurgeRecordingRequest) SbeTemplateId() (templateId uint16)

type PurgeSegmentsRequest 

type PurgeSegmentsRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
	NewStartPosition int64
}

func (*PurgeSegmentsRequest) ControlSessionIdDeprecated 

func (*PurgeSegmentsRequest) ControlSessionIdDeprecated() uint16

func (*PurgeSegmentsRequest) ControlSessionIdId 

func (*PurgeSegmentsRequest) ControlSessionIdId() uint16

func (*PurgeSegmentsRequest) ControlSessionIdInActingVersion 

func (p *PurgeSegmentsRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*PurgeSegmentsRequest) ControlSessionIdMaxValue 

func (*PurgeSegmentsRequest) ControlSessionIdMaxValue() int64

func (*PurgeSegmentsRequest) ControlSessionIdMetaAttribute 

func (*PurgeSegmentsRequest) ControlSessionIdMetaAttribute(meta int) string

func (*PurgeSegmentsRequest) ControlSessionIdMinValue 

func (*PurgeSegmentsRequest) ControlSessionIdMinValue() int64

func (*PurgeSegmentsRequest) ControlSessionIdNullValue 

func (*PurgeSegmentsRequest) ControlSessionIdNullValue() int64

func (*PurgeSegmentsRequest) ControlSessionIdSinceVersion 

func (*PurgeSegmentsRequest) ControlSessionIdSinceVersion() uint16

func (*PurgeSegmentsRequest) CorrelationIdDeprecated 

func (*PurgeSegmentsRequest) CorrelationIdDeprecated() uint16

func (*PurgeSegmentsRequest) CorrelationIdId 

func (*PurgeSegmentsRequest) CorrelationIdId() uint16

func (*PurgeSegmentsRequest) CorrelationIdInActingVersion 

func (p *PurgeSegmentsRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*PurgeSegmentsRequest) CorrelationIdMaxValue 

func (*PurgeSegmentsRequest) CorrelationIdMaxValue() int64

func (*PurgeSegmentsRequest) CorrelationIdMetaAttribute 

func (*PurgeSegmentsRequest) CorrelationIdMetaAttribute(meta int) string

func (*PurgeSegmentsRequest) CorrelationIdMinValue 

func (*PurgeSegmentsRequest) CorrelationIdMinValue() int64

func (*PurgeSegmentsRequest) CorrelationIdNullValue 

func (*PurgeSegmentsRequest) CorrelationIdNullValue() int64

func (*PurgeSegmentsRequest) CorrelationIdSinceVersion 

func (*PurgeSegmentsRequest) CorrelationIdSinceVersion() uint16

func (*PurgeSegmentsRequest) Decode 

func (p *PurgeSegmentsRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*PurgeSegmentsRequest) Encode 

func (p *PurgeSegmentsRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*PurgeSegmentsRequest) NewStartPositionDeprecated 

func (*PurgeSegmentsRequest) NewStartPositionDeprecated() uint16

func (*PurgeSegmentsRequest) NewStartPositionId 

func (*PurgeSegmentsRequest) NewStartPositionId() uint16

func (*PurgeSegmentsRequest) NewStartPositionInActingVersion 

func (p *PurgeSegmentsRequest) NewStartPositionInActingVersion(actingVersion uint16) bool

func (*PurgeSegmentsRequest) NewStartPositionMaxValue 

func (*PurgeSegmentsRequest) NewStartPositionMaxValue() int64

func (*PurgeSegmentsRequest) NewStartPositionMetaAttribute 

func (*PurgeSegmentsRequest) NewStartPositionMetaAttribute(meta int) string

func (*PurgeSegmentsRequest) NewStartPositionMinValue 

func (*PurgeSegmentsRequest) NewStartPositionMinValue() int64

func (*PurgeSegmentsRequest) NewStartPositionNullValue 

func (*PurgeSegmentsRequest) NewStartPositionNullValue() int64

func (*PurgeSegmentsRequest) NewStartPositionSinceVersion 

func (*PurgeSegmentsRequest) NewStartPositionSinceVersion() uint16

func (*PurgeSegmentsRequest) RangeCheck 

func (p *PurgeSegmentsRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*PurgeSegmentsRequest) RecordingIdDeprecated 

func (*PurgeSegmentsRequest) RecordingIdDeprecated() uint16

func (*PurgeSegmentsRequest) RecordingIdId 

func (*PurgeSegmentsRequest) RecordingIdId() uint16

func (*PurgeSegmentsRequest) RecordingIdInActingVersion 

func (p *PurgeSegmentsRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*PurgeSegmentsRequest) RecordingIdMaxValue 

func (*PurgeSegmentsRequest) RecordingIdMaxValue() int64

func (*PurgeSegmentsRequest) RecordingIdMetaAttribute 

func (*PurgeSegmentsRequest) RecordingIdMetaAttribute(meta int) string

func (*PurgeSegmentsRequest) RecordingIdMinValue 

func (*PurgeSegmentsRequest) RecordingIdMinValue() int64

func (*PurgeSegmentsRequest) RecordingIdNullValue 

func (*PurgeSegmentsRequest) RecordingIdNullValue() int64

func (*PurgeSegmentsRequest) RecordingIdSinceVersion 

func (*PurgeSegmentsRequest) RecordingIdSinceVersion() uint16

func (*PurgeSegmentsRequest) SbeBlockLength 

func (*PurgeSegmentsRequest) SbeBlockLength() (blockLength uint16)

func (*PurgeSegmentsRequest) SbeSchemaId 

func (*PurgeSegmentsRequest) SbeSchemaId() (schemaId uint16)

func (*PurgeSegmentsRequest) SbeSchemaVersion 

func (*PurgeSegmentsRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*PurgeSegmentsRequest) SbeSemanticType 

func (*PurgeSegmentsRequest) SbeSemanticType() (semanticType []byte)

func (*PurgeSegmentsRequest) SbeTemplateId 

func (*PurgeSegmentsRequest) SbeTemplateId() (templateId uint16)

type RecordingDescriptor 

type RecordingDescriptor struct {
	ControlSessionId  int64
	CorrelationId     int64
	RecordingId       int64
	StartTimestamp    int64
	StopTimestamp     int64
	StartPosition     int64
	StopPosition      int64
	InitialTermId     int32
	SegmentFileLength int32
	TermBufferLength  int32
	MtuLength         int32
	SessionId         int32
	StreamId          int32
	StrippedChannel   []uint8
	OriginalChannel   []uint8
	SourceIdentity    []uint8
}

func (*RecordingDescriptor) ControlSessionIdDeprecated 

func (*RecordingDescriptor) ControlSessionIdDeprecated() uint16

func (*RecordingDescriptor) ControlSessionIdId 

func (*RecordingDescriptor) ControlSessionIdId() uint16

func (*RecordingDescriptor) ControlSessionIdInActingVersion 

func (r *RecordingDescriptor) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) ControlSessionIdMaxValue 

func (*RecordingDescriptor) ControlSessionIdMaxValue() int64

func (*RecordingDescriptor) ControlSessionIdMetaAttribute 

func (*RecordingDescriptor) ControlSessionIdMetaAttribute(meta int) string

func (*RecordingDescriptor) ControlSessionIdMinValue 

func (*RecordingDescriptor) ControlSessionIdMinValue() int64

func (*RecordingDescriptor) ControlSessionIdNullValue 

func (*RecordingDescriptor) ControlSessionIdNullValue() int64

func (*RecordingDescriptor) ControlSessionIdSinceVersion 

func (*RecordingDescriptor) ControlSessionIdSinceVersion() uint16

func (*RecordingDescriptor) CorrelationIdDeprecated 

func (*RecordingDescriptor) CorrelationIdDeprecated() uint16

func (*RecordingDescriptor) CorrelationIdId 

func (*RecordingDescriptor) CorrelationIdId() uint16

func (*RecordingDescriptor) CorrelationIdInActingVersion 

func (r *RecordingDescriptor) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) CorrelationIdMaxValue 

func (*RecordingDescriptor) CorrelationIdMaxValue() int64

func (*RecordingDescriptor) CorrelationIdMetaAttribute 

func (*RecordingDescriptor) CorrelationIdMetaAttribute(meta int) string

func (*RecordingDescriptor) CorrelationIdMinValue 

func (*RecordingDescriptor) CorrelationIdMinValue() int64

func (*RecordingDescriptor) CorrelationIdNullValue 

func (*RecordingDescriptor) CorrelationIdNullValue() int64

func (*RecordingDescriptor) CorrelationIdSinceVersion 

func (*RecordingDescriptor) CorrelationIdSinceVersion() uint16

func (*RecordingDescriptor) Decode 

func (r *RecordingDescriptor) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*RecordingDescriptor) Encode 

func (r *RecordingDescriptor) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*RecordingDescriptor) InitialTermIdDeprecated 

func (*RecordingDescriptor) InitialTermIdDeprecated() uint16

func (*RecordingDescriptor) InitialTermIdId 

func (*RecordingDescriptor) InitialTermIdId() uint16

func (*RecordingDescriptor) InitialTermIdInActingVersion 

func (r *RecordingDescriptor) InitialTermIdInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) InitialTermIdMaxValue 

func (*RecordingDescriptor) InitialTermIdMaxValue() int32

func (*RecordingDescriptor) InitialTermIdMetaAttribute 

func (*RecordingDescriptor) InitialTermIdMetaAttribute(meta int) string

func (*RecordingDescriptor) InitialTermIdMinValue 

func (*RecordingDescriptor) InitialTermIdMinValue() int32

func (*RecordingDescriptor) InitialTermIdNullValue 

func (*RecordingDescriptor) InitialTermIdNullValue() int32

func (*RecordingDescriptor) InitialTermIdSinceVersion 

func (*RecordingDescriptor) InitialTermIdSinceVersion() uint16

func (*RecordingDescriptor) MtuLengthDeprecated 

func (*RecordingDescriptor) MtuLengthDeprecated() uint16

func (*RecordingDescriptor) MtuLengthId 

func (*RecordingDescriptor) MtuLengthId() uint16

func (*RecordingDescriptor) MtuLengthInActingVersion 

func (r *RecordingDescriptor) MtuLengthInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) MtuLengthMaxValue 

func (*RecordingDescriptor) MtuLengthMaxValue() int32

func (*RecordingDescriptor) MtuLengthMetaAttribute 

func (*RecordingDescriptor) MtuLengthMetaAttribute(meta int) string

func (*RecordingDescriptor) MtuLengthMinValue 

func (*RecordingDescriptor) MtuLengthMinValue() int32

func (*RecordingDescriptor) MtuLengthNullValue 

func (*RecordingDescriptor) MtuLengthNullValue() int32

func (*RecordingDescriptor) MtuLengthSinceVersion 

func (*RecordingDescriptor) MtuLengthSinceVersion() uint16

func (RecordingDescriptor) OriginalChannelCharacterEncoding 

func (RecordingDescriptor) OriginalChannelCharacterEncoding() string

func (*RecordingDescriptor) OriginalChannelDeprecated 

func (*RecordingDescriptor) OriginalChannelDeprecated() uint16

func (RecordingDescriptor) OriginalChannelHeaderLength 

func (RecordingDescriptor) OriginalChannelHeaderLength() uint64

func (*RecordingDescriptor) OriginalChannelInActingVersion 

func (r *RecordingDescriptor) OriginalChannelInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) OriginalChannelMetaAttribute 

func (*RecordingDescriptor) OriginalChannelMetaAttribute(meta int) string

func (*RecordingDescriptor) OriginalChannelSinceVersion 

func (*RecordingDescriptor) OriginalChannelSinceVersion() uint16

func (*RecordingDescriptor) RangeCheck 

func (r *RecordingDescriptor) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*RecordingDescriptor) RecordingIdDeprecated 

func (*RecordingDescriptor) RecordingIdDeprecated() uint16

func (*RecordingDescriptor) RecordingIdId 

func (*RecordingDescriptor) RecordingIdId() uint16

func (*RecordingDescriptor) RecordingIdInActingVersion 

func (r *RecordingDescriptor) RecordingIdInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) RecordingIdMaxValue 

func (*RecordingDescriptor) RecordingIdMaxValue() int64

func (*RecordingDescriptor) RecordingIdMetaAttribute 

func (*RecordingDescriptor) RecordingIdMetaAttribute(meta int) string

func (*RecordingDescriptor) RecordingIdMinValue 

func (*RecordingDescriptor) RecordingIdMinValue() int64

func (*RecordingDescriptor) RecordingIdNullValue 

func (*RecordingDescriptor) RecordingIdNullValue() int64

func (*RecordingDescriptor) RecordingIdSinceVersion 

func (*RecordingDescriptor) RecordingIdSinceVersion() uint16

func (*RecordingDescriptor) SbeBlockLength 

func (*RecordingDescriptor) SbeBlockLength() (blockLength uint16)

func (*RecordingDescriptor) SbeSchemaId 

func (*RecordingDescriptor) SbeSchemaId() (schemaId uint16)

func (*RecordingDescriptor) SbeSchemaVersion 

func (*RecordingDescriptor) SbeSchemaVersion() (schemaVersion uint16)

func (*RecordingDescriptor) SbeSemanticType 

func (*RecordingDescriptor) SbeSemanticType() (semanticType []byte)

func (*RecordingDescriptor) SbeTemplateId 

func (*RecordingDescriptor) SbeTemplateId() (templateId uint16)

func (*RecordingDescriptor) SegmentFileLengthDeprecated 

func (*RecordingDescriptor) SegmentFileLengthDeprecated() uint16

func (*RecordingDescriptor) SegmentFileLengthId 

func (*RecordingDescriptor) SegmentFileLengthId() uint16

func (*RecordingDescriptor) SegmentFileLengthInActingVersion 

func (r *RecordingDescriptor) SegmentFileLengthInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) SegmentFileLengthMaxValue 

func (*RecordingDescriptor) SegmentFileLengthMaxValue() int32

func (*RecordingDescriptor) SegmentFileLengthMetaAttribute 

func (*RecordingDescriptor) SegmentFileLengthMetaAttribute(meta int) string

func (*RecordingDescriptor) SegmentFileLengthMinValue 

func (*RecordingDescriptor) SegmentFileLengthMinValue() int32

func (*RecordingDescriptor) SegmentFileLengthNullValue 

func (*RecordingDescriptor) SegmentFileLengthNullValue() int32

func (*RecordingDescriptor) SegmentFileLengthSinceVersion 

func (*RecordingDescriptor) SegmentFileLengthSinceVersion() uint16

func (*RecordingDescriptor) SessionIdDeprecated 

func (*RecordingDescriptor) SessionIdDeprecated() uint16

func (*RecordingDescriptor) SessionIdId 

func (*RecordingDescriptor) SessionIdId() uint16

func (*RecordingDescriptor) SessionIdInActingVersion 

func (r *RecordingDescriptor) SessionIdInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) SessionIdMaxValue 

func (*RecordingDescriptor) SessionIdMaxValue() int32

func (*RecordingDescriptor) SessionIdMetaAttribute 

func (*RecordingDescriptor) SessionIdMetaAttribute(meta int) string

func (*RecordingDescriptor) SessionIdMinValue 

func (*RecordingDescriptor) SessionIdMinValue() int32

func (*RecordingDescriptor) SessionIdNullValue 

func (*RecordingDescriptor) SessionIdNullValue() int32

func (*RecordingDescriptor) SessionIdSinceVersion 

func (*RecordingDescriptor) SessionIdSinceVersion() uint16

func (RecordingDescriptor) SourceIdentityCharacterEncoding 

func (RecordingDescriptor) SourceIdentityCharacterEncoding() string

func (*RecordingDescriptor) SourceIdentityDeprecated 

func (*RecordingDescriptor) SourceIdentityDeprecated() uint16

func (RecordingDescriptor) SourceIdentityHeaderLength 

func (RecordingDescriptor) SourceIdentityHeaderLength() uint64

func (*RecordingDescriptor) SourceIdentityInActingVersion 

func (r *RecordingDescriptor) SourceIdentityInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) SourceIdentityMetaAttribute 

func (*RecordingDescriptor) SourceIdentityMetaAttribute(meta int) string

func (*RecordingDescriptor) SourceIdentitySinceVersion 

func (*RecordingDescriptor) SourceIdentitySinceVersion() uint16

func (*RecordingDescriptor) StartPositionDeprecated 

func (*RecordingDescriptor) StartPositionDeprecated() uint16

func (*RecordingDescriptor) StartPositionId 

func (*RecordingDescriptor) StartPositionId() uint16

func (*RecordingDescriptor) StartPositionInActingVersion 

func (r *RecordingDescriptor) StartPositionInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) StartPositionMaxValue 

func (*RecordingDescriptor) StartPositionMaxValue() int64

func (*RecordingDescriptor) StartPositionMetaAttribute 

func (*RecordingDescriptor) StartPositionMetaAttribute(meta int) string

func (*RecordingDescriptor) StartPositionMinValue 

func (*RecordingDescriptor) StartPositionMinValue() int64

func (*RecordingDescriptor) StartPositionNullValue 

func (*RecordingDescriptor) StartPositionNullValue() int64

func (*RecordingDescriptor) StartPositionSinceVersion 

func (*RecordingDescriptor) StartPositionSinceVersion() uint16

func (*RecordingDescriptor) StartTimestampDeprecated 

func (*RecordingDescriptor) StartTimestampDeprecated() uint16

func (*RecordingDescriptor) StartTimestampId 

func (*RecordingDescriptor) StartTimestampId() uint16

func (*RecordingDescriptor) StartTimestampInActingVersion 

func (r *RecordingDescriptor) StartTimestampInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) StartTimestampMaxValue 

func (*RecordingDescriptor) StartTimestampMaxValue() int64

func (*RecordingDescriptor) StartTimestampMetaAttribute 

func (*RecordingDescriptor) StartTimestampMetaAttribute(meta int) string

func (*RecordingDescriptor) StartTimestampMinValue 

func (*RecordingDescriptor) StartTimestampMinValue() int64

func (*RecordingDescriptor) StartTimestampNullValue 

func (*RecordingDescriptor) StartTimestampNullValue() int64

func (*RecordingDescriptor) StartTimestampSinceVersion 

func (*RecordingDescriptor) StartTimestampSinceVersion() uint16

func (*RecordingDescriptor) StopPositionDeprecated 

func (*RecordingDescriptor) StopPositionDeprecated() uint16

func (*RecordingDescriptor) StopPositionId 

func (*RecordingDescriptor) StopPositionId() uint16

func (*RecordingDescriptor) StopPositionInActingVersion 

func (r *RecordingDescriptor) StopPositionInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) StopPositionMaxValue 

func (*RecordingDescriptor) StopPositionMaxValue() int64

func (*RecordingDescriptor) StopPositionMetaAttribute 

func (*RecordingDescriptor) StopPositionMetaAttribute(meta int) string

func (*RecordingDescriptor) StopPositionMinValue 

func (*RecordingDescriptor) StopPositionMinValue() int64

func (*RecordingDescriptor) StopPositionNullValue 

func (*RecordingDescriptor) StopPositionNullValue() int64

func (*RecordingDescriptor) StopPositionSinceVersion 

func (*RecordingDescriptor) StopPositionSinceVersion() uint16

func (*RecordingDescriptor) StopTimestampDeprecated 

func (*RecordingDescriptor) StopTimestampDeprecated() uint16

func (*RecordingDescriptor) StopTimestampId 

func (*RecordingDescriptor) StopTimestampId() uint16

func (*RecordingDescriptor) StopTimestampInActingVersion 

func (r *RecordingDescriptor) StopTimestampInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) StopTimestampMaxValue 

func (*RecordingDescriptor) StopTimestampMaxValue() int64

func (*RecordingDescriptor) StopTimestampMetaAttribute 

func (*RecordingDescriptor) StopTimestampMetaAttribute(meta int) string

func (*RecordingDescriptor) StopTimestampMinValue 

func (*RecordingDescriptor) StopTimestampMinValue() int64

func (*RecordingDescriptor) StopTimestampNullValue 

func (*RecordingDescriptor) StopTimestampNullValue() int64

func (*RecordingDescriptor) StopTimestampSinceVersion 

func (*RecordingDescriptor) StopTimestampSinceVersion() uint16

func (*RecordingDescriptor) StreamIdDeprecated 

func (*RecordingDescriptor) StreamIdDeprecated() uint16

func (*RecordingDescriptor) StreamIdId 

func (*RecordingDescriptor) StreamIdId() uint16

func (*RecordingDescriptor) StreamIdInActingVersion 

func (r *RecordingDescriptor) StreamIdInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) StreamIdMaxValue 

func (*RecordingDescriptor) StreamIdMaxValue() int32

func (*RecordingDescriptor) StreamIdMetaAttribute 

func (*RecordingDescriptor) StreamIdMetaAttribute(meta int) string

func (*RecordingDescriptor) StreamIdMinValue 

func (*RecordingDescriptor) StreamIdMinValue() int32

func (*RecordingDescriptor) StreamIdNullValue 

func (*RecordingDescriptor) StreamIdNullValue() int32

func (*RecordingDescriptor) StreamIdSinceVersion 

func (*RecordingDescriptor) StreamIdSinceVersion() uint16

func (RecordingDescriptor) StrippedChannelCharacterEncoding 

func (RecordingDescriptor) StrippedChannelCharacterEncoding() string

func (*RecordingDescriptor) StrippedChannelDeprecated 

func (*RecordingDescriptor) StrippedChannelDeprecated() uint16

func (RecordingDescriptor) StrippedChannelHeaderLength 

func (RecordingDescriptor) StrippedChannelHeaderLength() uint64

func (*RecordingDescriptor) StrippedChannelInActingVersion 

func (r *RecordingDescriptor) StrippedChannelInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) StrippedChannelMetaAttribute 

func (*RecordingDescriptor) StrippedChannelMetaAttribute(meta int) string

func (*RecordingDescriptor) StrippedChannelSinceVersion 

func (*RecordingDescriptor) StrippedChannelSinceVersion() uint16

func (*RecordingDescriptor) TermBufferLengthDeprecated 

func (*RecordingDescriptor) TermBufferLengthDeprecated() uint16

func (*RecordingDescriptor) TermBufferLengthId 

func (*RecordingDescriptor) TermBufferLengthId() uint16

func (*RecordingDescriptor) TermBufferLengthInActingVersion 

func (r *RecordingDescriptor) TermBufferLengthInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptor) TermBufferLengthMaxValue 

func (*RecordingDescriptor) TermBufferLengthMaxValue() int32

func (*RecordingDescriptor) TermBufferLengthMetaAttribute 

func (*RecordingDescriptor) TermBufferLengthMetaAttribute(meta int) string

func (*RecordingDescriptor) TermBufferLengthMinValue 

func (*RecordingDescriptor) TermBufferLengthMinValue() int32

func (*RecordingDescriptor) TermBufferLengthNullValue 

func (*RecordingDescriptor) TermBufferLengthNullValue() int32

func (*RecordingDescriptor) TermBufferLengthSinceVersion 

func (*RecordingDescriptor) TermBufferLengthSinceVersion() uint16

type RecordingDescriptorHeader 

type RecordingDescriptorHeader struct {
	Length   int32
	State    RecordingStateEnum
	Checksum int32
	Reserved int8
}

func (*RecordingDescriptorHeader) ChecksumDeprecated 

func (*RecordingDescriptorHeader) ChecksumDeprecated() uint16

func (*RecordingDescriptorHeader) ChecksumId 

func (*RecordingDescriptorHeader) ChecksumId() uint16

func (*RecordingDescriptorHeader) ChecksumInActingVersion 

func (r *RecordingDescriptorHeader) ChecksumInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptorHeader) ChecksumMaxValue 

func (*RecordingDescriptorHeader) ChecksumMaxValue() int32

func (*RecordingDescriptorHeader) ChecksumMetaAttribute 

func (*RecordingDescriptorHeader) ChecksumMetaAttribute(meta int) string

func (*RecordingDescriptorHeader) ChecksumMinValue 

func (*RecordingDescriptorHeader) ChecksumMinValue() int32

func (*RecordingDescriptorHeader) ChecksumNullValue 

func (*RecordingDescriptorHeader) ChecksumNullValue() int32

func (*RecordingDescriptorHeader) ChecksumSinceVersion 

func (*RecordingDescriptorHeader) ChecksumSinceVersion() uint16

func (*RecordingDescriptorHeader) Decode 

func (r *RecordingDescriptorHeader) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*RecordingDescriptorHeader) Encode 

func (r *RecordingDescriptorHeader) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*RecordingDescriptorHeader) LengthDeprecated 

func (*RecordingDescriptorHeader) LengthDeprecated() uint16

func (*RecordingDescriptorHeader) LengthId 

func (*RecordingDescriptorHeader) LengthId() uint16

func (*RecordingDescriptorHeader) LengthInActingVersion 

func (r *RecordingDescriptorHeader) LengthInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptorHeader) LengthMaxValue 

func (*RecordingDescriptorHeader) LengthMaxValue() int32

func (*RecordingDescriptorHeader) LengthMetaAttribute 

func (*RecordingDescriptorHeader) LengthMetaAttribute(meta int) string

func (*RecordingDescriptorHeader) LengthMinValue 

func (*RecordingDescriptorHeader) LengthMinValue() int32

func (*RecordingDescriptorHeader) LengthNullValue 

func (*RecordingDescriptorHeader) LengthNullValue() int32

func (*RecordingDescriptorHeader) LengthSinceVersion 

func (*RecordingDescriptorHeader) LengthSinceVersion() uint16

func (*RecordingDescriptorHeader) RangeCheck 

func (r *RecordingDescriptorHeader) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*RecordingDescriptorHeader) ReservedDeprecated 

func (*RecordingDescriptorHeader) ReservedDeprecated() uint16

func (*RecordingDescriptorHeader) ReservedId 

func (*RecordingDescriptorHeader) ReservedId() uint16

func (*RecordingDescriptorHeader) ReservedInActingVersion 

func (r *RecordingDescriptorHeader) ReservedInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptorHeader) ReservedMaxValue 

func (*RecordingDescriptorHeader) ReservedMaxValue() int8

func (*RecordingDescriptorHeader) ReservedMetaAttribute 

func (*RecordingDescriptorHeader) ReservedMetaAttribute(meta int) string

func (*RecordingDescriptorHeader) ReservedMinValue 

func (*RecordingDescriptorHeader) ReservedMinValue() int8

func (*RecordingDescriptorHeader) ReservedNullValue 

func (*RecordingDescriptorHeader) ReservedNullValue() int8

func (*RecordingDescriptorHeader) ReservedSinceVersion 

func (*RecordingDescriptorHeader) ReservedSinceVersion() uint16

func (*RecordingDescriptorHeader) SbeBlockLength 

func (*RecordingDescriptorHeader) SbeBlockLength() (blockLength uint16)

func (*RecordingDescriptorHeader) SbeSchemaId 

func (*RecordingDescriptorHeader) SbeSchemaId() (schemaId uint16)

func (*RecordingDescriptorHeader) SbeSchemaVersion 

func (*RecordingDescriptorHeader) SbeSchemaVersion() (schemaVersion uint16)

func (*RecordingDescriptorHeader) SbeSemanticType 

func (*RecordingDescriptorHeader) SbeSemanticType() (semanticType []byte)

func (*RecordingDescriptorHeader) SbeTemplateId 

func (*RecordingDescriptorHeader) SbeTemplateId() (templateId uint16)

func (*RecordingDescriptorHeader) StateDeprecated 

func (*RecordingDescriptorHeader) StateDeprecated() uint16

func (*RecordingDescriptorHeader) StateId 

func (*RecordingDescriptorHeader) StateId() uint16

func (*RecordingDescriptorHeader) StateInActingVersion 

func (r *RecordingDescriptorHeader) StateInActingVersion(actingVersion uint16) bool

func (*RecordingDescriptorHeader) StateMetaAttribute 

func (*RecordingDescriptorHeader) StateMetaAttribute(meta int) string

func (*RecordingDescriptorHeader) StateSinceVersion 

func (*RecordingDescriptorHeader) StateSinceVersion() uint16

type RecordingPositionRequest 

type RecordingPositionRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
}

func (*RecordingPositionRequest) ControlSessionIdDeprecated 

func (*RecordingPositionRequest) ControlSessionIdDeprecated() uint16

func (*RecordingPositionRequest) ControlSessionIdId 

func (*RecordingPositionRequest) ControlSessionIdId() uint16

func (*RecordingPositionRequest) ControlSessionIdInActingVersion 

func (r *RecordingPositionRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*RecordingPositionRequest) ControlSessionIdMaxValue 

func (*RecordingPositionRequest) ControlSessionIdMaxValue() int64

func (*RecordingPositionRequest) ControlSessionIdMetaAttribute 

func (*RecordingPositionRequest) ControlSessionIdMetaAttribute(meta int) string

func (*RecordingPositionRequest) ControlSessionIdMinValue 

func (*RecordingPositionRequest) ControlSessionIdMinValue() int64

func (*RecordingPositionRequest) ControlSessionIdNullValue 

func (*RecordingPositionRequest) ControlSessionIdNullValue() int64

func (*RecordingPositionRequest) ControlSessionIdSinceVersion 

func (*RecordingPositionRequest) ControlSessionIdSinceVersion() uint16

func (*RecordingPositionRequest) CorrelationIdDeprecated 

func (*RecordingPositionRequest) CorrelationIdDeprecated() uint16

func (*RecordingPositionRequest) CorrelationIdId 

func (*RecordingPositionRequest) CorrelationIdId() uint16

func (*RecordingPositionRequest) CorrelationIdInActingVersion 

func (r *RecordingPositionRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*RecordingPositionRequest) CorrelationIdMaxValue 

func (*RecordingPositionRequest) CorrelationIdMaxValue() int64

func (*RecordingPositionRequest) CorrelationIdMetaAttribute 

func (*RecordingPositionRequest) CorrelationIdMetaAttribute(meta int) string

func (*RecordingPositionRequest) CorrelationIdMinValue 

func (*RecordingPositionRequest) CorrelationIdMinValue() int64

func (*RecordingPositionRequest) CorrelationIdNullValue 

func (*RecordingPositionRequest) CorrelationIdNullValue() int64

func (*RecordingPositionRequest) CorrelationIdSinceVersion 

func (*RecordingPositionRequest) CorrelationIdSinceVersion() uint16

func (*RecordingPositionRequest) Decode 

func (r *RecordingPositionRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*RecordingPositionRequest) Encode 

func (r *RecordingPositionRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*RecordingPositionRequest) RangeCheck 

func (r *RecordingPositionRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*RecordingPositionRequest) RecordingIdDeprecated 

func (*RecordingPositionRequest) RecordingIdDeprecated() uint16

func (*RecordingPositionRequest) RecordingIdId 

func (*RecordingPositionRequest) RecordingIdId() uint16

func (*RecordingPositionRequest) RecordingIdInActingVersion 

func (r *RecordingPositionRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*RecordingPositionRequest) RecordingIdMaxValue 

func (*RecordingPositionRequest) RecordingIdMaxValue() int64

func (*RecordingPositionRequest) RecordingIdMetaAttribute 

func (*RecordingPositionRequest) RecordingIdMetaAttribute(meta int) string

func (*RecordingPositionRequest) RecordingIdMinValue 

func (*RecordingPositionRequest) RecordingIdMinValue() int64

func (*RecordingPositionRequest) RecordingIdNullValue 

func (*RecordingPositionRequest) RecordingIdNullValue() int64

func (*RecordingPositionRequest) RecordingIdSinceVersion 

func (*RecordingPositionRequest) RecordingIdSinceVersion() uint16

func (*RecordingPositionRequest) SbeBlockLength 

func (*RecordingPositionRequest) SbeBlockLength() (blockLength uint16)

func (*RecordingPositionRequest) SbeSchemaId 

func (*RecordingPositionRequest) SbeSchemaId() (schemaId uint16)

func (*RecordingPositionRequest) SbeSchemaVersion 

func (*RecordingPositionRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*RecordingPositionRequest) SbeSemanticType 

func (*RecordingPositionRequest) SbeSemanticType() (semanticType []byte)

func (*RecordingPositionRequest) SbeTemplateId 

func (*RecordingPositionRequest) SbeTemplateId() (templateId uint16)

type RecordingProgress 

type RecordingProgress struct {
	RecordingId   int64
	StartPosition int64
	Position      int64
}

func (*RecordingProgress) Decode 

func (r *RecordingProgress) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*RecordingProgress) Encode 

func (r *RecordingProgress) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*RecordingProgress) PositionDeprecated 

func (*RecordingProgress) PositionDeprecated() uint16

func (*RecordingProgress) PositionId 

func (*RecordingProgress) PositionId() uint16

func (*RecordingProgress) PositionInActingVersion 

func (r *RecordingProgress) PositionInActingVersion(actingVersion uint16) bool

func (*RecordingProgress) PositionMaxValue 

func (*RecordingProgress) PositionMaxValue() int64

func (*RecordingProgress) PositionMetaAttribute 

func (*RecordingProgress) PositionMetaAttribute(meta int) string

func (*RecordingProgress) PositionMinValue 

func (*RecordingProgress) PositionMinValue() int64

func (*RecordingProgress) PositionNullValue 

func (*RecordingProgress) PositionNullValue() int64

func (*RecordingProgress) PositionSinceVersion 

func (*RecordingProgress) PositionSinceVersion() uint16

func (*RecordingProgress) RangeCheck 

func (r *RecordingProgress) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*RecordingProgress) RecordingIdDeprecated 

func (*RecordingProgress) RecordingIdDeprecated() uint16

func (*RecordingProgress) RecordingIdId 

func (*RecordingProgress) RecordingIdId() uint16

func (*RecordingProgress) RecordingIdInActingVersion 

func (r *RecordingProgress) RecordingIdInActingVersion(actingVersion uint16) bool

func (*RecordingProgress) RecordingIdMaxValue 

func (*RecordingProgress) RecordingIdMaxValue() int64

func (*RecordingProgress) RecordingIdMetaAttribute 

func (*RecordingProgress) RecordingIdMetaAttribute(meta int) string

func (*RecordingProgress) RecordingIdMinValue 

func (*RecordingProgress) RecordingIdMinValue() int64

func (*RecordingProgress) RecordingIdNullValue 

func (*RecordingProgress) RecordingIdNullValue() int64

func (*RecordingProgress) RecordingIdSinceVersion 

func (*RecordingProgress) RecordingIdSinceVersion() uint16

func (*RecordingProgress) SbeBlockLength 

func (*RecordingProgress) SbeBlockLength() (blockLength uint16)

func (*RecordingProgress) SbeSchemaId 

func (*RecordingProgress) SbeSchemaId() (schemaId uint16)

func (*RecordingProgress) SbeSchemaVersion 

func (*RecordingProgress) SbeSchemaVersion() (schemaVersion uint16)

func (*RecordingProgress) SbeSemanticType 

func (*RecordingProgress) SbeSemanticType() (semanticType []byte)

func (*RecordingProgress) SbeTemplateId 

func (*RecordingProgress) SbeTemplateId() (templateId uint16)

func (*RecordingProgress) StartPositionDeprecated 

func (*RecordingProgress) StartPositionDeprecated() uint16

func (*RecordingProgress) StartPositionId 

func (*RecordingProgress) StartPositionId() uint16

func (*RecordingProgress) StartPositionInActingVersion 

func (r *RecordingProgress) StartPositionInActingVersion(actingVersion uint16) bool

func (*RecordingProgress) StartPositionMaxValue 

func (*RecordingProgress) StartPositionMaxValue() int64

func (*RecordingProgress) StartPositionMetaAttribute 

func (*RecordingProgress) StartPositionMetaAttribute(meta int) string

func (*RecordingProgress) StartPositionMinValue 

func (*RecordingProgress) StartPositionMinValue() int64

func (*RecordingProgress) StartPositionNullValue 

func (*RecordingProgress) StartPositionNullValue() int64

func (*RecordingProgress) StartPositionSinceVersion 

func (*RecordingProgress) StartPositionSinceVersion() uint16

type RecordingSignalEnum 

type RecordingSignalEnum int32

func (*RecordingSignalEnum) DELETEDeprecated 

func (*RecordingSignalEnum) DELETEDeprecated() uint16

func (*RecordingSignalEnum) DELETEInActingVersion 

func (r *RecordingSignalEnum) DELETEInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEnum) DELETESinceVersion 

func (*RecordingSignalEnum) DELETESinceVersion() uint16

func (*RecordingSignalEnum) Decode 

func (r *RecordingSignalEnum) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16) error

func (*RecordingSignalEnum) EXTENDDeprecated 

func (*RecordingSignalEnum) EXTENDDeprecated() uint16

func (*RecordingSignalEnum) EXTENDInActingVersion 

func (r *RecordingSignalEnum) EXTENDInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEnum) EXTENDSinceVersion 

func (*RecordingSignalEnum) EXTENDSinceVersion() uint16

func (RecordingSignalEnum) Encode 

func (r RecordingSignalEnum) Encode(_m *SbeGoMarshaller, _w io.Writer) error

func (*RecordingSignalEnum) EncodedLength 

func (*RecordingSignalEnum) EncodedLength() int64

func (*RecordingSignalEnum) MERGEDeprecated 

func (*RecordingSignalEnum) MERGEDeprecated() uint16

func (*RecordingSignalEnum) MERGEInActingVersion 

func (r *RecordingSignalEnum) MERGEInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEnum) MERGESinceVersion 

func (*RecordingSignalEnum) MERGESinceVersion() uint16

func (*RecordingSignalEnum) REPLICATEDeprecated 

func (*RecordingSignalEnum) REPLICATEDeprecated() uint16

func (*RecordingSignalEnum) REPLICATEInActingVersion 

func (r *RecordingSignalEnum) REPLICATEInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEnum) REPLICATESinceVersion 

func (*RecordingSignalEnum) REPLICATESinceVersion() uint16

func (RecordingSignalEnum) RangeCheck 

func (r RecordingSignalEnum) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*RecordingSignalEnum) STARTDeprecated 

func (*RecordingSignalEnum) STARTDeprecated() uint16

func (*RecordingSignalEnum) STARTInActingVersion 

func (r *RecordingSignalEnum) STARTInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEnum) STARTSinceVersion 

func (*RecordingSignalEnum) STARTSinceVersion() uint16

func (*RecordingSignalEnum) STOPDeprecated 

func (*RecordingSignalEnum) STOPDeprecated() uint16

func (*RecordingSignalEnum) STOPInActingVersion 

func (r *RecordingSignalEnum) STOPInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEnum) STOPSinceVersion 

func (*RecordingSignalEnum) STOPSinceVersion() uint16

func (*RecordingSignalEnum) SYNCDeprecated 

func (*RecordingSignalEnum) SYNCDeprecated() uint16

func (*RecordingSignalEnum) SYNCInActingVersion 

func (r *RecordingSignalEnum) SYNCInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEnum) SYNCSinceVersion 

func (*RecordingSignalEnum) SYNCSinceVersion() uint16

type RecordingSignalEvent 

type RecordingSignalEvent struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
	SubscriptionId   int64
	Position         int64
	Signal           RecordingSignalEnum
}

func (*RecordingSignalEvent) ControlSessionIdDeprecated 

func (*RecordingSignalEvent) ControlSessionIdDeprecated() uint16

func (*RecordingSignalEvent) ControlSessionIdId 

func (*RecordingSignalEvent) ControlSessionIdId() uint16

func (*RecordingSignalEvent) ControlSessionIdInActingVersion 

func (r *RecordingSignalEvent) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEvent) ControlSessionIdMaxValue 

func (*RecordingSignalEvent) ControlSessionIdMaxValue() int64

func (*RecordingSignalEvent) ControlSessionIdMetaAttribute 

func (*RecordingSignalEvent) ControlSessionIdMetaAttribute(meta int) string

func (*RecordingSignalEvent) ControlSessionIdMinValue 

func (*RecordingSignalEvent) ControlSessionIdMinValue() int64

func (*RecordingSignalEvent) ControlSessionIdNullValue 

func (*RecordingSignalEvent) ControlSessionIdNullValue() int64

func (*RecordingSignalEvent) ControlSessionIdSinceVersion 

func (*RecordingSignalEvent) ControlSessionIdSinceVersion() uint16

func (*RecordingSignalEvent) CorrelationIdDeprecated 

func (*RecordingSignalEvent) CorrelationIdDeprecated() uint16

func (*RecordingSignalEvent) CorrelationIdId 

func (*RecordingSignalEvent) CorrelationIdId() uint16

func (*RecordingSignalEvent) CorrelationIdInActingVersion 

func (r *RecordingSignalEvent) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEvent) CorrelationIdMaxValue 

func (*RecordingSignalEvent) CorrelationIdMaxValue() int64

func (*RecordingSignalEvent) CorrelationIdMetaAttribute 

func (*RecordingSignalEvent) CorrelationIdMetaAttribute(meta int) string

func (*RecordingSignalEvent) CorrelationIdMinValue 

func (*RecordingSignalEvent) CorrelationIdMinValue() int64

func (*RecordingSignalEvent) CorrelationIdNullValue 

func (*RecordingSignalEvent) CorrelationIdNullValue() int64

func (*RecordingSignalEvent) CorrelationIdSinceVersion 

func (*RecordingSignalEvent) CorrelationIdSinceVersion() uint16

func (*RecordingSignalEvent) Decode 

func (r *RecordingSignalEvent) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*RecordingSignalEvent) Encode 

func (r *RecordingSignalEvent) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*RecordingSignalEvent) PositionDeprecated 

func (*RecordingSignalEvent) PositionDeprecated() uint16

func (*RecordingSignalEvent) PositionId 

func (*RecordingSignalEvent) PositionId() uint16

func (*RecordingSignalEvent) PositionInActingVersion 

func (r *RecordingSignalEvent) PositionInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEvent) PositionMaxValue 

func (*RecordingSignalEvent) PositionMaxValue() int64

func (*RecordingSignalEvent) PositionMetaAttribute 

func (*RecordingSignalEvent) PositionMetaAttribute(meta int) string

func (*RecordingSignalEvent) PositionMinValue 

func (*RecordingSignalEvent) PositionMinValue() int64

func (*RecordingSignalEvent) PositionNullValue 

func (*RecordingSignalEvent) PositionNullValue() int64

func (*RecordingSignalEvent) PositionSinceVersion 

func (*RecordingSignalEvent) PositionSinceVersion() uint16

func (*RecordingSignalEvent) RangeCheck 

func (r *RecordingSignalEvent) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*RecordingSignalEvent) RecordingIdDeprecated 

func (*RecordingSignalEvent) RecordingIdDeprecated() uint16

func (*RecordingSignalEvent) RecordingIdId 

func (*RecordingSignalEvent) RecordingIdId() uint16

func (*RecordingSignalEvent) RecordingIdInActingVersion 

func (r *RecordingSignalEvent) RecordingIdInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEvent) RecordingIdMaxValue 

func (*RecordingSignalEvent) RecordingIdMaxValue() int64

func (*RecordingSignalEvent) RecordingIdMetaAttribute 

func (*RecordingSignalEvent) RecordingIdMetaAttribute(meta int) string

func (*RecordingSignalEvent) RecordingIdMinValue 

func (*RecordingSignalEvent) RecordingIdMinValue() int64

func (*RecordingSignalEvent) RecordingIdNullValue 

func (*RecordingSignalEvent) RecordingIdNullValue() int64

func (*RecordingSignalEvent) RecordingIdSinceVersion 

func (*RecordingSignalEvent) RecordingIdSinceVersion() uint16

func (*RecordingSignalEvent) SbeBlockLength 

func (*RecordingSignalEvent) SbeBlockLength() (blockLength uint16)

func (*RecordingSignalEvent) SbeSchemaId 

func (*RecordingSignalEvent) SbeSchemaId() (schemaId uint16)

func (*RecordingSignalEvent) SbeSchemaVersion 

func (*RecordingSignalEvent) SbeSchemaVersion() (schemaVersion uint16)

func (*RecordingSignalEvent) SbeSemanticType 

func (*RecordingSignalEvent) SbeSemanticType() (semanticType []byte)

func (*RecordingSignalEvent) SbeTemplateId 

func (*RecordingSignalEvent) SbeTemplateId() (templateId uint16)

func (*RecordingSignalEvent) SignalDeprecated 

func (*RecordingSignalEvent) SignalDeprecated() uint16

func (*RecordingSignalEvent) SignalId 

func (*RecordingSignalEvent) SignalId() uint16

func (*RecordingSignalEvent) SignalInActingVersion 

func (r *RecordingSignalEvent) SignalInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEvent) SignalMetaAttribute 

func (*RecordingSignalEvent) SignalMetaAttribute(meta int) string

func (*RecordingSignalEvent) SignalSinceVersion 

func (*RecordingSignalEvent) SignalSinceVersion() uint16

func (*RecordingSignalEvent) SubscriptionIdDeprecated 

func (*RecordingSignalEvent) SubscriptionIdDeprecated() uint16

func (*RecordingSignalEvent) SubscriptionIdId 

func (*RecordingSignalEvent) SubscriptionIdId() uint16

func (*RecordingSignalEvent) SubscriptionIdInActingVersion 

func (r *RecordingSignalEvent) SubscriptionIdInActingVersion(actingVersion uint16) bool

func (*RecordingSignalEvent) SubscriptionIdMaxValue 

func (*RecordingSignalEvent) SubscriptionIdMaxValue() int64

func (*RecordingSignalEvent) SubscriptionIdMetaAttribute 

func (*RecordingSignalEvent) SubscriptionIdMetaAttribute(meta int) string

func (*RecordingSignalEvent) SubscriptionIdMinValue 

func (*RecordingSignalEvent) SubscriptionIdMinValue() int64

func (*RecordingSignalEvent) SubscriptionIdNullValue 

func (*RecordingSignalEvent) SubscriptionIdNullValue() int64

func (*RecordingSignalEvent) SubscriptionIdSinceVersion 

func (*RecordingSignalEvent) SubscriptionIdSinceVersion() uint16

type RecordingSignalValues 

type RecordingSignalValues struct {
	START     RecordingSignalEnum
	STOP      RecordingSignalEnum
	EXTEND    RecordingSignalEnum
	REPLICATE RecordingSignalEnum
	MERGE     RecordingSignalEnum
	SYNC      RecordingSignalEnum
	DELETE    RecordingSignalEnum
	NullValue RecordingSignalEnum
}

type RecordingStarted 

type RecordingStarted struct {
	RecordingId    int64
	StartPosition  int64
	SessionId      int32
	StreamId       int32
	Channel        []uint8
	SourceIdentity []uint8
}

func (RecordingStarted) ChannelCharacterEncoding 

func (RecordingStarted) ChannelCharacterEncoding() string

func (*RecordingStarted) ChannelDeprecated 

func (*RecordingStarted) ChannelDeprecated() uint16

func (RecordingStarted) ChannelHeaderLength 

func (RecordingStarted) ChannelHeaderLength() uint64

func (*RecordingStarted) ChannelInActingVersion 

func (r *RecordingStarted) ChannelInActingVersion(actingVersion uint16) bool

func (*RecordingStarted) ChannelMetaAttribute 

func (*RecordingStarted) ChannelMetaAttribute(meta int) string

func (*RecordingStarted) ChannelSinceVersion 

func (*RecordingStarted) ChannelSinceVersion() uint16

func (*RecordingStarted) Decode 

func (r *RecordingStarted) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*RecordingStarted) Encode 

func (r *RecordingStarted) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*RecordingStarted) RangeCheck 

func (r *RecordingStarted) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*RecordingStarted) RecordingIdDeprecated 

func (*RecordingStarted) RecordingIdDeprecated() uint16

func (*RecordingStarted) RecordingIdId 

func (*RecordingStarted) RecordingIdId() uint16

func (*RecordingStarted) RecordingIdInActingVersion 

func (r *RecordingStarted) RecordingIdInActingVersion(actingVersion uint16) bool

func (*RecordingStarted) RecordingIdMaxValue 

func (*RecordingStarted) RecordingIdMaxValue() int64

func (*RecordingStarted) RecordingIdMetaAttribute 

func (*RecordingStarted) RecordingIdMetaAttribute(meta int) string

func (*RecordingStarted) RecordingIdMinValue 

func (*RecordingStarted) RecordingIdMinValue() int64

func (*RecordingStarted) RecordingIdNullValue 

func (*RecordingStarted) RecordingIdNullValue() int64

func (*RecordingStarted) RecordingIdSinceVersion 

func (*RecordingStarted) RecordingIdSinceVersion() uint16

func (*RecordingStarted) SbeBlockLength 

func (*RecordingStarted) SbeBlockLength() (blockLength uint16)

func (*RecordingStarted) SbeSchemaId 

func (*RecordingStarted) SbeSchemaId() (schemaId uint16)

func (*RecordingStarted) SbeSchemaVersion 

func (*RecordingStarted) SbeSchemaVersion() (schemaVersion uint16)

func (*RecordingStarted) SbeSemanticType 

func (*RecordingStarted) SbeSemanticType() (semanticType []byte)

func (*RecordingStarted) SbeTemplateId 

func (*RecordingStarted) SbeTemplateId() (templateId uint16)

func (*RecordingStarted) SessionIdDeprecated 

func (*RecordingStarted) SessionIdDeprecated() uint16

func (*RecordingStarted) SessionIdId 

func (*RecordingStarted) SessionIdId() uint16

func (*RecordingStarted) SessionIdInActingVersion 

func (r *RecordingStarted) SessionIdInActingVersion(actingVersion uint16) bool

func (*RecordingStarted) SessionIdMaxValue 

func (*RecordingStarted) SessionIdMaxValue() int32

func (*RecordingStarted) SessionIdMetaAttribute 

func (*RecordingStarted) SessionIdMetaAttribute(meta int) string

func (*RecordingStarted) SessionIdMinValue 

func (*RecordingStarted) SessionIdMinValue() int32

func (*RecordingStarted) SessionIdNullValue 

func (*RecordingStarted) SessionIdNullValue() int32

func (*RecordingStarted) SessionIdSinceVersion 

func (*RecordingStarted) SessionIdSinceVersion() uint16

func (RecordingStarted) SourceIdentityCharacterEncoding 

func (RecordingStarted) SourceIdentityCharacterEncoding() string

func (*RecordingStarted) SourceIdentityDeprecated 

func (*RecordingStarted) SourceIdentityDeprecated() uint16

func (RecordingStarted) SourceIdentityHeaderLength 

func (RecordingStarted) SourceIdentityHeaderLength() uint64

func (*RecordingStarted) SourceIdentityInActingVersion 

func (r *RecordingStarted) SourceIdentityInActingVersion(actingVersion uint16) bool

func (*RecordingStarted) SourceIdentityMetaAttribute 

func (*RecordingStarted) SourceIdentityMetaAttribute(meta int) string

func (*RecordingStarted) SourceIdentitySinceVersion 

func (*RecordingStarted) SourceIdentitySinceVersion() uint16

func (*RecordingStarted) StartPositionDeprecated 

func (*RecordingStarted) StartPositionDeprecated() uint16

func (*RecordingStarted) StartPositionId 

func (*RecordingStarted) StartPositionId() uint16

func (*RecordingStarted) StartPositionInActingVersion 

func (r *RecordingStarted) StartPositionInActingVersion(actingVersion uint16) bool

func (*RecordingStarted) StartPositionMaxValue 

func (*RecordingStarted) StartPositionMaxValue() int64

func (*RecordingStarted) StartPositionMetaAttribute 

func (*RecordingStarted) StartPositionMetaAttribute(meta int) string

func (*RecordingStarted) StartPositionMinValue 

func (*RecordingStarted) StartPositionMinValue() int64

func (*RecordingStarted) StartPositionNullValue 

func (*RecordingStarted) StartPositionNullValue() int64

func (*RecordingStarted) StartPositionSinceVersion 

func (*RecordingStarted) StartPositionSinceVersion() uint16

func (*RecordingStarted) StreamIdDeprecated 

func (*RecordingStarted) StreamIdDeprecated() uint16

func (*RecordingStarted) StreamIdId 

func (*RecordingStarted) StreamIdId() uint16

func (*RecordingStarted) StreamIdInActingVersion 

func (r *RecordingStarted) StreamIdInActingVersion(actingVersion uint16) bool

func (*RecordingStarted) StreamIdMaxValue 

func (*RecordingStarted) StreamIdMaxValue() int32

func (*RecordingStarted) StreamIdMetaAttribute 

func (*RecordingStarted) StreamIdMetaAttribute(meta int) string

func (*RecordingStarted) StreamIdMinValue 

func (*RecordingStarted) StreamIdMinValue() int32

func (*RecordingStarted) StreamIdNullValue 

func (*RecordingStarted) StreamIdNullValue() int32

func (*RecordingStarted) StreamIdSinceVersion 

func (*RecordingStarted) StreamIdSinceVersion() uint16

type RecordingStateEnum 

type RecordingStateEnum int32

func (*RecordingStateEnum) Decode 

func (r *RecordingStateEnum) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16) error

func (RecordingStateEnum) Encode 

func (r RecordingStateEnum) Encode(_m *SbeGoMarshaller, _w io.Writer) error

func (*RecordingStateEnum) EncodedLength 

func (*RecordingStateEnum) EncodedLength() int64

func (*RecordingStateEnum) INVALIDDeprecated 

func (*RecordingStateEnum) INVALIDDeprecated() uint16

func (*RecordingStateEnum) INVALIDInActingVersion 

func (r *RecordingStateEnum) INVALIDInActingVersion(actingVersion uint16) bool

func (*RecordingStateEnum) INVALIDSinceVersion 

func (*RecordingStateEnum) INVALIDSinceVersion() uint16

func (RecordingStateEnum) RangeCheck 

func (r RecordingStateEnum) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*RecordingStateEnum) VALIDDeprecated 

func (*RecordingStateEnum) VALIDDeprecated() uint16

func (*RecordingStateEnum) VALIDInActingVersion 

func (r *RecordingStateEnum) VALIDInActingVersion(actingVersion uint16) bool

func (*RecordingStateEnum) VALIDSinceVersion 

func (*RecordingStateEnum) VALIDSinceVersion() uint16

type RecordingStateValues 

type RecordingStateValues struct {
	INVALID   RecordingStateEnum
	VALID     RecordingStateEnum
	NullValue RecordingStateEnum
}

type RecordingStopped 

type RecordingStopped struct {
	RecordingId   int64
	StartPosition int64
	StopPosition  int64
}

func (*RecordingStopped) Decode 

func (r *RecordingStopped) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*RecordingStopped) Encode 

func (r *RecordingStopped) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*RecordingStopped) RangeCheck 

func (r *RecordingStopped) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*RecordingStopped) RecordingIdDeprecated 

func (*RecordingStopped) RecordingIdDeprecated() uint16

func (*RecordingStopped) RecordingIdId 

func (*RecordingStopped) RecordingIdId() uint16

func (*RecordingStopped) RecordingIdInActingVersion 

func (r *RecordingStopped) RecordingIdInActingVersion(actingVersion uint16) bool

func (*RecordingStopped) RecordingIdMaxValue 

func (*RecordingStopped) RecordingIdMaxValue() int64

func (*RecordingStopped) RecordingIdMetaAttribute 

func (*RecordingStopped) RecordingIdMetaAttribute(meta int) string

func (*RecordingStopped) RecordingIdMinValue 

func (*RecordingStopped) RecordingIdMinValue() int64

func (*RecordingStopped) RecordingIdNullValue 

func (*RecordingStopped) RecordingIdNullValue() int64

func (*RecordingStopped) RecordingIdSinceVersion 

func (*RecordingStopped) RecordingIdSinceVersion() uint16

func (*RecordingStopped) SbeBlockLength 

func (*RecordingStopped) SbeBlockLength() (blockLength uint16)

func (*RecordingStopped) SbeSchemaId 

func (*RecordingStopped) SbeSchemaId() (schemaId uint16)

func (*RecordingStopped) SbeSchemaVersion 

func (*RecordingStopped) SbeSchemaVersion() (schemaVersion uint16)

func (*RecordingStopped) SbeSemanticType 

func (*RecordingStopped) SbeSemanticType() (semanticType []byte)

func (*RecordingStopped) SbeTemplateId 

func (*RecordingStopped) SbeTemplateId() (templateId uint16)

func (*RecordingStopped) StartPositionDeprecated 

func (*RecordingStopped) StartPositionDeprecated() uint16

func (*RecordingStopped) StartPositionId 

func (*RecordingStopped) StartPositionId() uint16

func (*RecordingStopped) StartPositionInActingVersion 

func (r *RecordingStopped) StartPositionInActingVersion(actingVersion uint16) bool

func (*RecordingStopped) StartPositionMaxValue 

func (*RecordingStopped) StartPositionMaxValue() int64

func (*RecordingStopped) StartPositionMetaAttribute 

func (*RecordingStopped) StartPositionMetaAttribute(meta int) string

func (*RecordingStopped) StartPositionMinValue 

func (*RecordingStopped) StartPositionMinValue() int64

func (*RecordingStopped) StartPositionNullValue 

func (*RecordingStopped) StartPositionNullValue() int64

func (*RecordingStopped) StartPositionSinceVersion 

func (*RecordingStopped) StartPositionSinceVersion() uint16

func (*RecordingStopped) StopPositionDeprecated 

func (*RecordingStopped) StopPositionDeprecated() uint16

func (*RecordingStopped) StopPositionId 

func (*RecordingStopped) StopPositionId() uint16

func (*RecordingStopped) StopPositionInActingVersion 

func (r *RecordingStopped) StopPositionInActingVersion(actingVersion uint16) bool

func (*RecordingStopped) StopPositionMaxValue 

func (*RecordingStopped) StopPositionMaxValue() int64

func (*RecordingStopped) StopPositionMetaAttribute 

func (*RecordingStopped) StopPositionMetaAttribute(meta int) string

func (*RecordingStopped) StopPositionMinValue 

func (*RecordingStopped) StopPositionMinValue() int64

func (*RecordingStopped) StopPositionNullValue 

func (*RecordingStopped) StopPositionNullValue() int64

func (*RecordingStopped) StopPositionSinceVersion 

func (*RecordingStopped) StopPositionSinceVersion() uint16

type RecordingSubscriptionDescriptor 

type RecordingSubscriptionDescriptor struct {
	ControlSessionId int64
	CorrelationId    int64
	SubscriptionId   int64
	StreamId         int32
	StrippedChannel  []uint8
}

func (*RecordingSubscriptionDescriptor) ControlSessionIdDeprecated 

func (*RecordingSubscriptionDescriptor) ControlSessionIdDeprecated() uint16

func (*RecordingSubscriptionDescriptor) ControlSessionIdId 

func (*RecordingSubscriptionDescriptor) ControlSessionIdId() uint16

func (*RecordingSubscriptionDescriptor) ControlSessionIdInActingVersion 

func (r *RecordingSubscriptionDescriptor) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*RecordingSubscriptionDescriptor) ControlSessionIdMaxValue 

func (*RecordingSubscriptionDescriptor) ControlSessionIdMaxValue() int64

func (*RecordingSubscriptionDescriptor) ControlSessionIdMetaAttribute 

func (*RecordingSubscriptionDescriptor) ControlSessionIdMetaAttribute(meta int) string

func (*RecordingSubscriptionDescriptor) ControlSessionIdMinValue 

func (*RecordingSubscriptionDescriptor) ControlSessionIdMinValue() int64

func (*RecordingSubscriptionDescriptor) ControlSessionIdNullValue 

func (*RecordingSubscriptionDescriptor) ControlSessionIdNullValue() int64

func (*RecordingSubscriptionDescriptor) ControlSessionIdSinceVersion 

func (*RecordingSubscriptionDescriptor) ControlSessionIdSinceVersion() uint16

func (*RecordingSubscriptionDescriptor) CorrelationIdDeprecated 

func (*RecordingSubscriptionDescriptor) CorrelationIdDeprecated() uint16

func (*RecordingSubscriptionDescriptor) CorrelationIdId 

func (*RecordingSubscriptionDescriptor) CorrelationIdId() uint16

func (*RecordingSubscriptionDescriptor) CorrelationIdInActingVersion 

func (r *RecordingSubscriptionDescriptor) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*RecordingSubscriptionDescriptor) CorrelationIdMaxValue 

func (*RecordingSubscriptionDescriptor) CorrelationIdMaxValue() int64

func (*RecordingSubscriptionDescriptor) CorrelationIdMetaAttribute 

func (*RecordingSubscriptionDescriptor) CorrelationIdMetaAttribute(meta int) string

func (*RecordingSubscriptionDescriptor) CorrelationIdMinValue 

func (*RecordingSubscriptionDescriptor) CorrelationIdMinValue() int64

func (*RecordingSubscriptionDescriptor) CorrelationIdNullValue 

func (*RecordingSubscriptionDescriptor) CorrelationIdNullValue() int64

func (*RecordingSubscriptionDescriptor) CorrelationIdSinceVersion 

func (*RecordingSubscriptionDescriptor) CorrelationIdSinceVersion() uint16

func (*RecordingSubscriptionDescriptor) Decode 

func (r *RecordingSubscriptionDescriptor) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*RecordingSubscriptionDescriptor) Encode 

func (r *RecordingSubscriptionDescriptor) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*RecordingSubscriptionDescriptor) RangeCheck 

func (r *RecordingSubscriptionDescriptor) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*RecordingSubscriptionDescriptor) SbeBlockLength 

func (*RecordingSubscriptionDescriptor) SbeBlockLength() (blockLength uint16)

func (*RecordingSubscriptionDescriptor) SbeSchemaId 

func (*RecordingSubscriptionDescriptor) SbeSchemaId() (schemaId uint16)

func (*RecordingSubscriptionDescriptor) SbeSchemaVersion 

func (*RecordingSubscriptionDescriptor) SbeSchemaVersion() (schemaVersion uint16)

func (*RecordingSubscriptionDescriptor) SbeSemanticType 

func (*RecordingSubscriptionDescriptor) SbeSemanticType() (semanticType []byte)

func (*RecordingSubscriptionDescriptor) SbeTemplateId 

func (*RecordingSubscriptionDescriptor) SbeTemplateId() (templateId uint16)

func (*RecordingSubscriptionDescriptor) StreamIdDeprecated 

func (*RecordingSubscriptionDescriptor) StreamIdDeprecated() uint16

func (*RecordingSubscriptionDescriptor) StreamIdId 

func (*RecordingSubscriptionDescriptor) StreamIdId() uint16

func (*RecordingSubscriptionDescriptor) StreamIdInActingVersion 

func (r *RecordingSubscriptionDescriptor) StreamIdInActingVersion(actingVersion uint16) bool

func (*RecordingSubscriptionDescriptor) StreamIdMaxValue 

func (*RecordingSubscriptionDescriptor) StreamIdMaxValue() int32

func (*RecordingSubscriptionDescriptor) StreamIdMetaAttribute 

func (*RecordingSubscriptionDescriptor) StreamIdMetaAttribute(meta int) string

func (*RecordingSubscriptionDescriptor) StreamIdMinValue 

func (*RecordingSubscriptionDescriptor) StreamIdMinValue() int32

func (*RecordingSubscriptionDescriptor) StreamIdNullValue 

func (*RecordingSubscriptionDescriptor) StreamIdNullValue() int32

func (*RecordingSubscriptionDescriptor) StreamIdSinceVersion 

func (*RecordingSubscriptionDescriptor) StreamIdSinceVersion() uint16

func (RecordingSubscriptionDescriptor) StrippedChannelCharacterEncoding 

func (RecordingSubscriptionDescriptor) StrippedChannelCharacterEncoding() string

func (*RecordingSubscriptionDescriptor) StrippedChannelDeprecated 

func (*RecordingSubscriptionDescriptor) StrippedChannelDeprecated() uint16

func (RecordingSubscriptionDescriptor) StrippedChannelHeaderLength 

func (RecordingSubscriptionDescriptor) StrippedChannelHeaderLength() uint64

func (*RecordingSubscriptionDescriptor) StrippedChannelInActingVersion 

func (r *RecordingSubscriptionDescriptor) StrippedChannelInActingVersion(actingVersion uint16) bool

func (*RecordingSubscriptionDescriptor) StrippedChannelMetaAttribute 

func (*RecordingSubscriptionDescriptor) StrippedChannelMetaAttribute(meta int) string

func (*RecordingSubscriptionDescriptor) StrippedChannelSinceVersion 

func (*RecordingSubscriptionDescriptor) StrippedChannelSinceVersion() uint16

func (*RecordingSubscriptionDescriptor) SubscriptionIdDeprecated 

func (*RecordingSubscriptionDescriptor) SubscriptionIdDeprecated() uint16

func (*RecordingSubscriptionDescriptor) SubscriptionIdId 

func (*RecordingSubscriptionDescriptor) SubscriptionIdId() uint16

func (*RecordingSubscriptionDescriptor) SubscriptionIdInActingVersion 

func (r *RecordingSubscriptionDescriptor) SubscriptionIdInActingVersion(actingVersion uint16) bool

func (*RecordingSubscriptionDescriptor) SubscriptionIdMaxValue 

func (*RecordingSubscriptionDescriptor) SubscriptionIdMaxValue() int64

func (*RecordingSubscriptionDescriptor) SubscriptionIdMetaAttribute 

func (*RecordingSubscriptionDescriptor) SubscriptionIdMetaAttribute(meta int) string

func (*RecordingSubscriptionDescriptor) SubscriptionIdMinValue 

func (*RecordingSubscriptionDescriptor) SubscriptionIdMinValue() int64

func (*RecordingSubscriptionDescriptor) SubscriptionIdNullValue 

func (*RecordingSubscriptionDescriptor) SubscriptionIdNullValue() int64

func (*RecordingSubscriptionDescriptor) SubscriptionIdSinceVersion 

func (*RecordingSubscriptionDescriptor) SubscriptionIdSinceVersion() uint16

type ReplayRequest 

type ReplayRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
	Position         int64
	Length           int64
	ReplayStreamId   int32
	ReplayChannel    []uint8
}

func (*ReplayRequest) ControlSessionIdDeprecated 

func (*ReplayRequest) ControlSessionIdDeprecated() uint16

func (*ReplayRequest) ControlSessionIdId 

func (*ReplayRequest) ControlSessionIdId() uint16

func (*ReplayRequest) ControlSessionIdInActingVersion 

func (r *ReplayRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ReplayRequest) ControlSessionIdMaxValue 

func (*ReplayRequest) ControlSessionIdMaxValue() int64

func (*ReplayRequest) ControlSessionIdMetaAttribute 

func (*ReplayRequest) ControlSessionIdMetaAttribute(meta int) string

func (*ReplayRequest) ControlSessionIdMinValue 

func (*ReplayRequest) ControlSessionIdMinValue() int64

func (*ReplayRequest) ControlSessionIdNullValue 

func (*ReplayRequest) ControlSessionIdNullValue() int64

func (*ReplayRequest) ControlSessionIdSinceVersion 

func (*ReplayRequest) ControlSessionIdSinceVersion() uint16

func (*ReplayRequest) CorrelationIdDeprecated 

func (*ReplayRequest) CorrelationIdDeprecated() uint16

func (*ReplayRequest) CorrelationIdId 

func (*ReplayRequest) CorrelationIdId() uint16

func (*ReplayRequest) CorrelationIdInActingVersion 

func (r *ReplayRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ReplayRequest) CorrelationIdMaxValue 

func (*ReplayRequest) CorrelationIdMaxValue() int64

func (*ReplayRequest) CorrelationIdMetaAttribute 

func (*ReplayRequest) CorrelationIdMetaAttribute(meta int) string

func (*ReplayRequest) CorrelationIdMinValue 

func (*ReplayRequest) CorrelationIdMinValue() int64

func (*ReplayRequest) CorrelationIdNullValue 

func (*ReplayRequest) CorrelationIdNullValue() int64

func (*ReplayRequest) CorrelationIdSinceVersion 

func (*ReplayRequest) CorrelationIdSinceVersion() uint16

func (*ReplayRequest) Decode 

func (r *ReplayRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ReplayRequest) Encode 

func (r *ReplayRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*ReplayRequest) LengthDeprecated 

func (*ReplayRequest) LengthDeprecated() uint16

func (*ReplayRequest) LengthId 

func (*ReplayRequest) LengthId() uint16

func (*ReplayRequest) LengthInActingVersion 

func (r *ReplayRequest) LengthInActingVersion(actingVersion uint16) bool

func (*ReplayRequest) LengthMaxValue 

func (*ReplayRequest) LengthMaxValue() int64

func (*ReplayRequest) LengthMetaAttribute 

func (*ReplayRequest) LengthMetaAttribute(meta int) string

func (*ReplayRequest) LengthMinValue 

func (*ReplayRequest) LengthMinValue() int64

func (*ReplayRequest) LengthNullValue 

func (*ReplayRequest) LengthNullValue() int64

func (*ReplayRequest) LengthSinceVersion 

func (*ReplayRequest) LengthSinceVersion() uint16

func (*ReplayRequest) PositionDeprecated 

func (*ReplayRequest) PositionDeprecated() uint16

func (*ReplayRequest) PositionId 

func (*ReplayRequest) PositionId() uint16

func (*ReplayRequest) PositionInActingVersion 

func (r *ReplayRequest) PositionInActingVersion(actingVersion uint16) bool

func (*ReplayRequest) PositionMaxValue 

func (*ReplayRequest) PositionMaxValue() int64

func (*ReplayRequest) PositionMetaAttribute 

func (*ReplayRequest) PositionMetaAttribute(meta int) string

func (*ReplayRequest) PositionMinValue 

func (*ReplayRequest) PositionMinValue() int64

func (*ReplayRequest) PositionNullValue 

func (*ReplayRequest) PositionNullValue() int64

func (*ReplayRequest) PositionSinceVersion 

func (*ReplayRequest) PositionSinceVersion() uint16

func (*ReplayRequest) RangeCheck 

func (r *ReplayRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ReplayRequest) RecordingIdDeprecated 

func (*ReplayRequest) RecordingIdDeprecated() uint16

func (*ReplayRequest) RecordingIdId 

func (*ReplayRequest) RecordingIdId() uint16

func (*ReplayRequest) RecordingIdInActingVersion 

func (r *ReplayRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*ReplayRequest) RecordingIdMaxValue 

func (*ReplayRequest) RecordingIdMaxValue() int64

func (*ReplayRequest) RecordingIdMetaAttribute 

func (*ReplayRequest) RecordingIdMetaAttribute(meta int) string

func (*ReplayRequest) RecordingIdMinValue 

func (*ReplayRequest) RecordingIdMinValue() int64

func (*ReplayRequest) RecordingIdNullValue 

func (*ReplayRequest) RecordingIdNullValue() int64

func (*ReplayRequest) RecordingIdSinceVersion 

func (*ReplayRequest) RecordingIdSinceVersion() uint16

func (ReplayRequest) ReplayChannelCharacterEncoding 

func (ReplayRequest) ReplayChannelCharacterEncoding() string

func (*ReplayRequest) ReplayChannelDeprecated 

func (*ReplayRequest) ReplayChannelDeprecated() uint16

func (ReplayRequest) ReplayChannelHeaderLength 

func (ReplayRequest) ReplayChannelHeaderLength() uint64

func (*ReplayRequest) ReplayChannelInActingVersion 

func (r *ReplayRequest) ReplayChannelInActingVersion(actingVersion uint16) bool

func (*ReplayRequest) ReplayChannelMetaAttribute 

func (*ReplayRequest) ReplayChannelMetaAttribute(meta int) string

func (*ReplayRequest) ReplayChannelSinceVersion 

func (*ReplayRequest) ReplayChannelSinceVersion() uint16

func (*ReplayRequest) ReplayStreamIdDeprecated 

func (*ReplayRequest) ReplayStreamIdDeprecated() uint16

func (*ReplayRequest) ReplayStreamIdId 

func (*ReplayRequest) ReplayStreamIdId() uint16

func (*ReplayRequest) ReplayStreamIdInActingVersion 

func (r *ReplayRequest) ReplayStreamIdInActingVersion(actingVersion uint16) bool

func (*ReplayRequest) ReplayStreamIdMaxValue 

func (*ReplayRequest) ReplayStreamIdMaxValue() int32

func (*ReplayRequest) ReplayStreamIdMetaAttribute 

func (*ReplayRequest) ReplayStreamIdMetaAttribute(meta int) string

func (*ReplayRequest) ReplayStreamIdMinValue 

func (*ReplayRequest) ReplayStreamIdMinValue() int32

func (*ReplayRequest) ReplayStreamIdNullValue 

func (*ReplayRequest) ReplayStreamIdNullValue() int32

func (*ReplayRequest) ReplayStreamIdSinceVersion 

func (*ReplayRequest) ReplayStreamIdSinceVersion() uint16

func (*ReplayRequest) SbeBlockLength 

func (*ReplayRequest) SbeBlockLength() (blockLength uint16)

func (*ReplayRequest) SbeSchemaId 

func (*ReplayRequest) SbeSchemaId() (schemaId uint16)

func (*ReplayRequest) SbeSchemaVersion 

func (*ReplayRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*ReplayRequest) SbeSemanticType 

func (*ReplayRequest) SbeSemanticType() (semanticType []byte)

func (*ReplayRequest) SbeTemplateId 

func (*ReplayRequest) SbeTemplateId() (templateId uint16)

type ReplicateRequest 

type ReplicateRequest struct {
	ControlSessionId   int64
	CorrelationId      int64
	SrcRecordingId     int64
	DstRecordingId     int64
	SrcControlStreamId int32
	SrcControlChannel  []uint8
	LiveDestination    []uint8
}

func (*ReplicateRequest) ControlSessionIdDeprecated 

func (*ReplicateRequest) ControlSessionIdDeprecated() uint16

func (*ReplicateRequest) ControlSessionIdId 

func (*ReplicateRequest) ControlSessionIdId() uint16

func (*ReplicateRequest) ControlSessionIdInActingVersion 

func (r *ReplicateRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest) ControlSessionIdMaxValue 

func (*ReplicateRequest) ControlSessionIdMaxValue() int64

func (*ReplicateRequest) ControlSessionIdMetaAttribute 

func (*ReplicateRequest) ControlSessionIdMetaAttribute(meta int) string

func (*ReplicateRequest) ControlSessionIdMinValue 

func (*ReplicateRequest) ControlSessionIdMinValue() int64

func (*ReplicateRequest) ControlSessionIdNullValue 

func (*ReplicateRequest) ControlSessionIdNullValue() int64

func (*ReplicateRequest) ControlSessionIdSinceVersion 

func (*ReplicateRequest) ControlSessionIdSinceVersion() uint16

func (*ReplicateRequest) CorrelationIdDeprecated 

func (*ReplicateRequest) CorrelationIdDeprecated() uint16

func (*ReplicateRequest) CorrelationIdId 

func (*ReplicateRequest) CorrelationIdId() uint16

func (*ReplicateRequest) CorrelationIdInActingVersion 

func (r *ReplicateRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest) CorrelationIdMaxValue 

func (*ReplicateRequest) CorrelationIdMaxValue() int64

func (*ReplicateRequest) CorrelationIdMetaAttribute 

func (*ReplicateRequest) CorrelationIdMetaAttribute(meta int) string

func (*ReplicateRequest) CorrelationIdMinValue 

func (*ReplicateRequest) CorrelationIdMinValue() int64

func (*ReplicateRequest) CorrelationIdNullValue 

func (*ReplicateRequest) CorrelationIdNullValue() int64

func (*ReplicateRequest) CorrelationIdSinceVersion 

func (*ReplicateRequest) CorrelationIdSinceVersion() uint16

func (*ReplicateRequest) Decode 

func (r *ReplicateRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ReplicateRequest) DstRecordingIdDeprecated 

func (*ReplicateRequest) DstRecordingIdDeprecated() uint16

func (*ReplicateRequest) DstRecordingIdId 

func (*ReplicateRequest) DstRecordingIdId() uint16

func (*ReplicateRequest) DstRecordingIdInActingVersion 

func (r *ReplicateRequest) DstRecordingIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest) DstRecordingIdMaxValue 

func (*ReplicateRequest) DstRecordingIdMaxValue() int64

func (*ReplicateRequest) DstRecordingIdMetaAttribute 

func (*ReplicateRequest) DstRecordingIdMetaAttribute(meta int) string

func (*ReplicateRequest) DstRecordingIdMinValue 

func (*ReplicateRequest) DstRecordingIdMinValue() int64

func (*ReplicateRequest) DstRecordingIdNullValue 

func (*ReplicateRequest) DstRecordingIdNullValue() int64

func (*ReplicateRequest) DstRecordingIdSinceVersion 

func (*ReplicateRequest) DstRecordingIdSinceVersion() uint16

func (*ReplicateRequest) Encode 

func (r *ReplicateRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (ReplicateRequest) LiveDestinationCharacterEncoding 

func (ReplicateRequest) LiveDestinationCharacterEncoding() string

func (*ReplicateRequest) LiveDestinationDeprecated 

func (*ReplicateRequest) LiveDestinationDeprecated() uint16

func (ReplicateRequest) LiveDestinationHeaderLength 

func (ReplicateRequest) LiveDestinationHeaderLength() uint64

func (*ReplicateRequest) LiveDestinationInActingVersion 

func (r *ReplicateRequest) LiveDestinationInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest) LiveDestinationMetaAttribute 

func (*ReplicateRequest) LiveDestinationMetaAttribute(meta int) string

func (*ReplicateRequest) LiveDestinationSinceVersion 

func (*ReplicateRequest) LiveDestinationSinceVersion() uint16

func (*ReplicateRequest) RangeCheck 

func (r *ReplicateRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*ReplicateRequest) SbeBlockLength 

func (*ReplicateRequest) SbeBlockLength() (blockLength uint16)

func (*ReplicateRequest) SbeSchemaId 

func (*ReplicateRequest) SbeSchemaId() (schemaId uint16)

func (*ReplicateRequest) SbeSchemaVersion 

func (*ReplicateRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*ReplicateRequest) SbeSemanticType 

func (*ReplicateRequest) SbeSemanticType() (semanticType []byte)

func (*ReplicateRequest) SbeTemplateId 

func (*ReplicateRequest) SbeTemplateId() (templateId uint16)

func (ReplicateRequest) SrcControlChannelCharacterEncoding 

func (ReplicateRequest) SrcControlChannelCharacterEncoding() string

func (*ReplicateRequest) SrcControlChannelDeprecated 

func (*ReplicateRequest) SrcControlChannelDeprecated() uint16

func (ReplicateRequest) SrcControlChannelHeaderLength 

func (ReplicateRequest) SrcControlChannelHeaderLength() uint64

func (*ReplicateRequest) SrcControlChannelInActingVersion 

func (r *ReplicateRequest) SrcControlChannelInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest) SrcControlChannelMetaAttribute 

func (*ReplicateRequest) SrcControlChannelMetaAttribute(meta int) string

func (*ReplicateRequest) SrcControlChannelSinceVersion 

func (*ReplicateRequest) SrcControlChannelSinceVersion() uint16

func (*ReplicateRequest) SrcControlStreamIdDeprecated 

func (*ReplicateRequest) SrcControlStreamIdDeprecated() uint16

func (*ReplicateRequest) SrcControlStreamIdId 

func (*ReplicateRequest) SrcControlStreamIdId() uint16

func (*ReplicateRequest) SrcControlStreamIdInActingVersion 

func (r *ReplicateRequest) SrcControlStreamIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest) SrcControlStreamIdMaxValue 

func (*ReplicateRequest) SrcControlStreamIdMaxValue() int32

func (*ReplicateRequest) SrcControlStreamIdMetaAttribute 

func (*ReplicateRequest) SrcControlStreamIdMetaAttribute(meta int) string

func (*ReplicateRequest) SrcControlStreamIdMinValue 

func (*ReplicateRequest) SrcControlStreamIdMinValue() int32

func (*ReplicateRequest) SrcControlStreamIdNullValue 

func (*ReplicateRequest) SrcControlStreamIdNullValue() int32

func (*ReplicateRequest) SrcControlStreamIdSinceVersion 

func (*ReplicateRequest) SrcControlStreamIdSinceVersion() uint16

func (*ReplicateRequest) SrcRecordingIdDeprecated 

func (*ReplicateRequest) SrcRecordingIdDeprecated() uint16

func (*ReplicateRequest) SrcRecordingIdId 

func (*ReplicateRequest) SrcRecordingIdId() uint16

func (*ReplicateRequest) SrcRecordingIdInActingVersion 

func (r *ReplicateRequest) SrcRecordingIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest) SrcRecordingIdMaxValue 

func (*ReplicateRequest) SrcRecordingIdMaxValue() int64

func (*ReplicateRequest) SrcRecordingIdMetaAttribute 

func (*ReplicateRequest) SrcRecordingIdMetaAttribute(meta int) string

func (*ReplicateRequest) SrcRecordingIdMinValue 

func (*ReplicateRequest) SrcRecordingIdMinValue() int64

func (*ReplicateRequest) SrcRecordingIdNullValue 

func (*ReplicateRequest) SrcRecordingIdNullValue() int64

func (*ReplicateRequest) SrcRecordingIdSinceVersion 

func (*ReplicateRequest) SrcRecordingIdSinceVersion() uint16

type ReplicateRequest2 

type ReplicateRequest2 struct {
	ControlSessionId   int64
	CorrelationId      int64
	SrcRecordingId     int64
	DstRecordingId     int64
	StopPosition       int64
	ChannelTagId       int64
	SubscriptionTagId  int64
	SrcControlStreamId int32
	SrcControlChannel  []uint8
	LiveDestination    []uint8
	ReplicationChannel []uint8
}

func (*ReplicateRequest2) ChannelTagIdDeprecated 

func (*ReplicateRequest2) ChannelTagIdDeprecated() uint16

func (*ReplicateRequest2) ChannelTagIdId 

func (*ReplicateRequest2) ChannelTagIdId() uint16

func (*ReplicateRequest2) ChannelTagIdInActingVersion 

func (r *ReplicateRequest2) ChannelTagIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) ChannelTagIdMaxValue 

func (*ReplicateRequest2) ChannelTagIdMaxValue() int64

func (*ReplicateRequest2) ChannelTagIdMetaAttribute 

func (*ReplicateRequest2) ChannelTagIdMetaAttribute(meta int) string

func (*ReplicateRequest2) ChannelTagIdMinValue 

func (*ReplicateRequest2) ChannelTagIdMinValue() int64

func (*ReplicateRequest2) ChannelTagIdNullValue 

func (*ReplicateRequest2) ChannelTagIdNullValue() int64

func (*ReplicateRequest2) ChannelTagIdSinceVersion 

func (*ReplicateRequest2) ChannelTagIdSinceVersion() uint16

func (*ReplicateRequest2) ControlSessionIdDeprecated 

func (*ReplicateRequest2) ControlSessionIdDeprecated() uint16

func (*ReplicateRequest2) ControlSessionIdId 

func (*ReplicateRequest2) ControlSessionIdId() uint16

func (*ReplicateRequest2) ControlSessionIdInActingVersion 

func (r *ReplicateRequest2) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) ControlSessionIdMaxValue 

func (*ReplicateRequest2) ControlSessionIdMaxValue() int64

func (*ReplicateRequest2) ControlSessionIdMetaAttribute 

func (*ReplicateRequest2) ControlSessionIdMetaAttribute(meta int) string

func (*ReplicateRequest2) ControlSessionIdMinValue 

func (*ReplicateRequest2) ControlSessionIdMinValue() int64

func (*ReplicateRequest2) ControlSessionIdNullValue 

func (*ReplicateRequest2) ControlSessionIdNullValue() int64

func (*ReplicateRequest2) ControlSessionIdSinceVersion 

func (*ReplicateRequest2) ControlSessionIdSinceVersion() uint16

func (*ReplicateRequest2) CorrelationIdDeprecated 

func (*ReplicateRequest2) CorrelationIdDeprecated() uint16

func (*ReplicateRequest2) CorrelationIdId 

func (*ReplicateRequest2) CorrelationIdId() uint16

func (*ReplicateRequest2) CorrelationIdInActingVersion 

func (r *ReplicateRequest2) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) CorrelationIdMaxValue 

func (*ReplicateRequest2) CorrelationIdMaxValue() int64

func (*ReplicateRequest2) CorrelationIdMetaAttribute 

func (*ReplicateRequest2) CorrelationIdMetaAttribute(meta int) string

func (*ReplicateRequest2) CorrelationIdMinValue 

func (*ReplicateRequest2) CorrelationIdMinValue() int64

func (*ReplicateRequest2) CorrelationIdNullValue 

func (*ReplicateRequest2) CorrelationIdNullValue() int64

func (*ReplicateRequest2) CorrelationIdSinceVersion 

func (*ReplicateRequest2) CorrelationIdSinceVersion() uint16

func (*ReplicateRequest2) Decode 

func (r *ReplicateRequest2) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*ReplicateRequest2) DstRecordingIdDeprecated 

func (*ReplicateRequest2) DstRecordingIdDeprecated() uint16

func (*ReplicateRequest2) DstRecordingIdId 

func (*ReplicateRequest2) DstRecordingIdId() uint16

func (*ReplicateRequest2) DstRecordingIdInActingVersion 

func (r *ReplicateRequest2) DstRecordingIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) DstRecordingIdMaxValue 

func (*ReplicateRequest2) DstRecordingIdMaxValue() int64

func (*ReplicateRequest2) DstRecordingIdMetaAttribute 

func (*ReplicateRequest2) DstRecordingIdMetaAttribute(meta int) string

func (*ReplicateRequest2) DstRecordingIdMinValue 

func (*ReplicateRequest2) DstRecordingIdMinValue() int64

func (*ReplicateRequest2) DstRecordingIdNullValue 

func (*ReplicateRequest2) DstRecordingIdNullValue() int64

func (*ReplicateRequest2) DstRecordingIdSinceVersion 

func (*ReplicateRequest2) DstRecordingIdSinceVersion() uint16

func (*ReplicateRequest2) Encode 

func (r *ReplicateRequest2) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (ReplicateRequest2) LiveDestinationCharacterEncoding 

func (ReplicateRequest2) LiveDestinationCharacterEncoding() string

func (*ReplicateRequest2) LiveDestinationDeprecated 

func (*ReplicateRequest2) LiveDestinationDeprecated() uint16

func (ReplicateRequest2) LiveDestinationHeaderLength 

func (ReplicateRequest2) LiveDestinationHeaderLength() uint64

func (*ReplicateRequest2) LiveDestinationInActingVersion 

func (r *ReplicateRequest2) LiveDestinationInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) LiveDestinationMetaAttribute 

func (*ReplicateRequest2) LiveDestinationMetaAttribute(meta int) string

func (*ReplicateRequest2) LiveDestinationSinceVersion 

func (*ReplicateRequest2) LiveDestinationSinceVersion() uint16

func (*ReplicateRequest2) RangeCheck 

func (r *ReplicateRequest2) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (ReplicateRequest2) ReplicationChannelCharacterEncoding 

func (ReplicateRequest2) ReplicationChannelCharacterEncoding() string

func (*ReplicateRequest2) ReplicationChannelDeprecated 

func (*ReplicateRequest2) ReplicationChannelDeprecated() uint16

func (ReplicateRequest2) ReplicationChannelHeaderLength 

func (ReplicateRequest2) ReplicationChannelHeaderLength() uint64

func (*ReplicateRequest2) ReplicationChannelInActingVersion 

func (r *ReplicateRequest2) ReplicationChannelInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) ReplicationChannelMetaAttribute 

func (*ReplicateRequest2) ReplicationChannelMetaAttribute(meta int) string

func (*ReplicateRequest2) ReplicationChannelSinceVersion 

func (*ReplicateRequest2) ReplicationChannelSinceVersion() uint16

func (*ReplicateRequest2) SbeBlockLength 

func (*ReplicateRequest2) SbeBlockLength() (blockLength uint16)

func (*ReplicateRequest2) SbeSchemaId 

func (*ReplicateRequest2) SbeSchemaId() (schemaId uint16)

func (*ReplicateRequest2) SbeSchemaVersion 

func (*ReplicateRequest2) SbeSchemaVersion() (schemaVersion uint16)

func (*ReplicateRequest2) SbeSemanticType 

func (*ReplicateRequest2) SbeSemanticType() (semanticType []byte)

func (*ReplicateRequest2) SbeTemplateId 

func (*ReplicateRequest2) SbeTemplateId() (templateId uint16)

func (ReplicateRequest2) SrcControlChannelCharacterEncoding 

func (ReplicateRequest2) SrcControlChannelCharacterEncoding() string

func (*ReplicateRequest2) SrcControlChannelDeprecated 

func (*ReplicateRequest2) SrcControlChannelDeprecated() uint16

func (ReplicateRequest2) SrcControlChannelHeaderLength 

func (ReplicateRequest2) SrcControlChannelHeaderLength() uint64

func (*ReplicateRequest2) SrcControlChannelInActingVersion 

func (r *ReplicateRequest2) SrcControlChannelInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) SrcControlChannelMetaAttribute 

func (*ReplicateRequest2) SrcControlChannelMetaAttribute(meta int) string

func (*ReplicateRequest2) SrcControlChannelSinceVersion 

func (*ReplicateRequest2) SrcControlChannelSinceVersion() uint16

func (*ReplicateRequest2) SrcControlStreamIdDeprecated 

func (*ReplicateRequest2) SrcControlStreamIdDeprecated() uint16

func (*ReplicateRequest2) SrcControlStreamIdId 

func (*ReplicateRequest2) SrcControlStreamIdId() uint16

func (*ReplicateRequest2) SrcControlStreamIdInActingVersion 

func (r *ReplicateRequest2) SrcControlStreamIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) SrcControlStreamIdMaxValue 

func (*ReplicateRequest2) SrcControlStreamIdMaxValue() int32

func (*ReplicateRequest2) SrcControlStreamIdMetaAttribute 

func (*ReplicateRequest2) SrcControlStreamIdMetaAttribute(meta int) string

func (*ReplicateRequest2) SrcControlStreamIdMinValue 

func (*ReplicateRequest2) SrcControlStreamIdMinValue() int32

func (*ReplicateRequest2) SrcControlStreamIdNullValue 

func (*ReplicateRequest2) SrcControlStreamIdNullValue() int32

func (*ReplicateRequest2) SrcControlStreamIdSinceVersion 

func (*ReplicateRequest2) SrcControlStreamIdSinceVersion() uint16

func (*ReplicateRequest2) SrcRecordingIdDeprecated 

func (*ReplicateRequest2) SrcRecordingIdDeprecated() uint16

func (*ReplicateRequest2) SrcRecordingIdId 

func (*ReplicateRequest2) SrcRecordingIdId() uint16

func (*ReplicateRequest2) SrcRecordingIdInActingVersion 

func (r *ReplicateRequest2) SrcRecordingIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) SrcRecordingIdMaxValue 

func (*ReplicateRequest2) SrcRecordingIdMaxValue() int64

func (*ReplicateRequest2) SrcRecordingIdMetaAttribute 

func (*ReplicateRequest2) SrcRecordingIdMetaAttribute(meta int) string

func (*ReplicateRequest2) SrcRecordingIdMinValue 

func (*ReplicateRequest2) SrcRecordingIdMinValue() int64

func (*ReplicateRequest2) SrcRecordingIdNullValue 

func (*ReplicateRequest2) SrcRecordingIdNullValue() int64

func (*ReplicateRequest2) SrcRecordingIdSinceVersion 

func (*ReplicateRequest2) SrcRecordingIdSinceVersion() uint16

func (*ReplicateRequest2) StopPositionDeprecated 

func (*ReplicateRequest2) StopPositionDeprecated() uint16

func (*ReplicateRequest2) StopPositionId 

func (*ReplicateRequest2) StopPositionId() uint16

func (*ReplicateRequest2) StopPositionInActingVersion 

func (r *ReplicateRequest2) StopPositionInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) StopPositionMaxValue 

func (*ReplicateRequest2) StopPositionMaxValue() int64

func (*ReplicateRequest2) StopPositionMetaAttribute 

func (*ReplicateRequest2) StopPositionMetaAttribute(meta int) string

func (*ReplicateRequest2) StopPositionMinValue 

func (*ReplicateRequest2) StopPositionMinValue() int64

func (*ReplicateRequest2) StopPositionNullValue 

func (*ReplicateRequest2) StopPositionNullValue() int64

func (*ReplicateRequest2) StopPositionSinceVersion 

func (*ReplicateRequest2) StopPositionSinceVersion() uint16

func (*ReplicateRequest2) SubscriptionTagIdDeprecated 

func (*ReplicateRequest2) SubscriptionTagIdDeprecated() uint16

func (*ReplicateRequest2) SubscriptionTagIdId 

func (*ReplicateRequest2) SubscriptionTagIdId() uint16

func (*ReplicateRequest2) SubscriptionTagIdInActingVersion 

func (r *ReplicateRequest2) SubscriptionTagIdInActingVersion(actingVersion uint16) bool

func (*ReplicateRequest2) SubscriptionTagIdMaxValue 

func (*ReplicateRequest2) SubscriptionTagIdMaxValue() int64

func (*ReplicateRequest2) SubscriptionTagIdMetaAttribute 

func (*ReplicateRequest2) SubscriptionTagIdMetaAttribute(meta int) string

func (*ReplicateRequest2) SubscriptionTagIdMinValue 

func (*ReplicateRequest2) SubscriptionTagIdMinValue() int64

func (*ReplicateRequest2) SubscriptionTagIdNullValue 

func (*ReplicateRequest2) SubscriptionTagIdNullValue() int64

func (*ReplicateRequest2) SubscriptionTagIdSinceVersion 

func (*ReplicateRequest2) SubscriptionTagIdSinceVersion() uint16

type SbeGoMarshaller 

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

Allocate via NewSbeGoMarshaller to initialize

func NewSbeGoMarshaller 

func NewSbeGoMarshaller() *SbeGoMarshaller

func (*SbeGoMarshaller) ReadBytes 

func (m *SbeGoMarshaller) ReadBytes(r io.Reader, b []byte) error

func (*SbeGoMarshaller) ReadFloat32 

func (m *SbeGoMarshaller) ReadFloat32(r io.Reader, v *float32) error

func (*SbeGoMarshaller) ReadFloat64 

func (m *SbeGoMarshaller) ReadFloat64(r io.Reader, v *float64) error

func (*SbeGoMarshaller) ReadInt16 

func (m *SbeGoMarshaller) ReadInt16(r io.Reader, v *int16) error

func (*SbeGoMarshaller) ReadInt32 

func (m *SbeGoMarshaller) ReadInt32(r io.Reader, v *int32) error

func (*SbeGoMarshaller) ReadInt64 

func (m *SbeGoMarshaller) ReadInt64(r io.Reader, v *int64) error

func (*SbeGoMarshaller) ReadInt8 

func (m *SbeGoMarshaller) ReadInt8(r io.Reader, v *int8) error

func (*SbeGoMarshaller) ReadUint16 

func (m *SbeGoMarshaller) ReadUint16(r io.Reader, v *uint16) error

func (*SbeGoMarshaller) ReadUint32 

func (m *SbeGoMarshaller) ReadUint32(r io.Reader, v *uint32) error

func (*SbeGoMarshaller) ReadUint64 

func (m *SbeGoMarshaller) ReadUint64(r io.Reader, v *uint64) error

func (*SbeGoMarshaller) ReadUint8 

func (m *SbeGoMarshaller) ReadUint8(r io.Reader, v *uint8) error

func (*SbeGoMarshaller) WriteBytes 

func (m *SbeGoMarshaller) WriteBytes(w io.Writer, v []byte) error

func (*SbeGoMarshaller) WriteFloat32 

func (m *SbeGoMarshaller) WriteFloat32(w io.Writer, v float32) error

func (*SbeGoMarshaller) WriteFloat64 

func (m *SbeGoMarshaller) WriteFloat64(w io.Writer, v float64) error

func (*SbeGoMarshaller) WriteInt16 

func (m *SbeGoMarshaller) WriteInt16(w io.Writer, v int16) error

func (*SbeGoMarshaller) WriteInt32 

func (m *SbeGoMarshaller) WriteInt32(w io.Writer, v int32) error

func (*SbeGoMarshaller) WriteInt64 

func (m *SbeGoMarshaller) WriteInt64(w io.Writer, v int64) error

func (*SbeGoMarshaller) WriteInt8 

func (m *SbeGoMarshaller) WriteInt8(w io.Writer, v int8) error

func (*SbeGoMarshaller) WriteUint16 

func (m *SbeGoMarshaller) WriteUint16(w io.Writer, v uint16) error

func (*SbeGoMarshaller) WriteUint32 

func (m *SbeGoMarshaller) WriteUint32(w io.Writer, v uint32) error

func (*SbeGoMarshaller) WriteUint64 

func (m *SbeGoMarshaller) WriteUint64(w io.Writer, v uint64) error

func (*SbeGoMarshaller) WriteUint8 

func (m *SbeGoMarshaller) WriteUint8(w io.Writer, v uint8) error

type SbeGoMessageHeader 

type SbeGoMessageHeader struct {
	BlockLength uint16
	TemplateId  uint16
	SchemaId    uint16
	Version     uint16
}

The "standard" MessageHeader.

Most applications will use this as it's the default and optimized although it's possible to change it by: a) using a different sized BlockLength, or b) adding arbitrary fields

If the MessageHeader is not "standard" then you can use the generated MessageHeader type in MessageHeader.go otherwise we recommend this one.

func (*SbeGoMessageHeader) Decode 

func (m *SbeGoMessageHeader) Decode(_m *SbeGoMarshaller, _r io.Reader) error

func (SbeGoMessageHeader) Encode 

func (m SbeGoMessageHeader) Encode(_m *SbeGoMarshaller, _w io.Writer) error

type SourceLocationEnum 

type SourceLocationEnum int32

func (*SourceLocationEnum) Decode 

func (s *SourceLocationEnum) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16) error

func (SourceLocationEnum) Encode 

func (s SourceLocationEnum) Encode(_m *SbeGoMarshaller, _w io.Writer) error

func (*SourceLocationEnum) EncodedLength 

func (*SourceLocationEnum) EncodedLength() int64

func (*SourceLocationEnum) LOCALDeprecated 

func (*SourceLocationEnum) LOCALDeprecated() uint16

func (*SourceLocationEnum) LOCALInActingVersion 

func (s *SourceLocationEnum) LOCALInActingVersion(actingVersion uint16) bool

func (*SourceLocationEnum) LOCALSinceVersion 

func (*SourceLocationEnum) LOCALSinceVersion() uint16

func (*SourceLocationEnum) REMOTEDeprecated 

func (*SourceLocationEnum) REMOTEDeprecated() uint16

func (*SourceLocationEnum) REMOTEInActingVersion 

func (s *SourceLocationEnum) REMOTEInActingVersion(actingVersion uint16) bool

func (*SourceLocationEnum) REMOTESinceVersion 

func (*SourceLocationEnum) REMOTESinceVersion() uint16

func (SourceLocationEnum) RangeCheck 

func (s SourceLocationEnum) RangeCheck(actingVersion uint16, schemaVersion uint16) error

type SourceLocationValues 

type SourceLocationValues struct {
	LOCAL     SourceLocationEnum
	REMOTE    SourceLocationEnum
	NullValue SourceLocationEnum
}

type StartPositionRequest 

type StartPositionRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
}

func (*StartPositionRequest) ControlSessionIdDeprecated 

func (*StartPositionRequest) ControlSessionIdDeprecated() uint16

func (*StartPositionRequest) ControlSessionIdId 

func (*StartPositionRequest) ControlSessionIdId() uint16

func (*StartPositionRequest) ControlSessionIdInActingVersion 

func (s *StartPositionRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*StartPositionRequest) ControlSessionIdMaxValue 

func (*StartPositionRequest) ControlSessionIdMaxValue() int64

func (*StartPositionRequest) ControlSessionIdMetaAttribute 

func (*StartPositionRequest) ControlSessionIdMetaAttribute(meta int) string

func (*StartPositionRequest) ControlSessionIdMinValue 

func (*StartPositionRequest) ControlSessionIdMinValue() int64

func (*StartPositionRequest) ControlSessionIdNullValue 

func (*StartPositionRequest) ControlSessionIdNullValue() int64

func (*StartPositionRequest) ControlSessionIdSinceVersion 

func (*StartPositionRequest) ControlSessionIdSinceVersion() uint16

func (*StartPositionRequest) CorrelationIdDeprecated 

func (*StartPositionRequest) CorrelationIdDeprecated() uint16

func (*StartPositionRequest) CorrelationIdId 

func (*StartPositionRequest) CorrelationIdId() uint16

func (*StartPositionRequest) CorrelationIdInActingVersion 

func (s *StartPositionRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*StartPositionRequest) CorrelationIdMaxValue 

func (*StartPositionRequest) CorrelationIdMaxValue() int64

func (*StartPositionRequest) CorrelationIdMetaAttribute 

func (*StartPositionRequest) CorrelationIdMetaAttribute(meta int) string

func (*StartPositionRequest) CorrelationIdMinValue 

func (*StartPositionRequest) CorrelationIdMinValue() int64

func (*StartPositionRequest) CorrelationIdNullValue 

func (*StartPositionRequest) CorrelationIdNullValue() int64

func (*StartPositionRequest) CorrelationIdSinceVersion 

func (*StartPositionRequest) CorrelationIdSinceVersion() uint16

func (*StartPositionRequest) Decode 

func (s *StartPositionRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*StartPositionRequest) Encode 

func (s *StartPositionRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*StartPositionRequest) RangeCheck 

func (s *StartPositionRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*StartPositionRequest) RecordingIdDeprecated 

func (*StartPositionRequest) RecordingIdDeprecated() uint16

func (*StartPositionRequest) RecordingIdId 

func (*StartPositionRequest) RecordingIdId() uint16

func (*StartPositionRequest) RecordingIdInActingVersion 

func (s *StartPositionRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*StartPositionRequest) RecordingIdMaxValue 

func (*StartPositionRequest) RecordingIdMaxValue() int64

func (*StartPositionRequest) RecordingIdMetaAttribute 

func (*StartPositionRequest) RecordingIdMetaAttribute(meta int) string

func (*StartPositionRequest) RecordingIdMinValue 

func (*StartPositionRequest) RecordingIdMinValue() int64

func (*StartPositionRequest) RecordingIdNullValue 

func (*StartPositionRequest) RecordingIdNullValue() int64

func (*StartPositionRequest) RecordingIdSinceVersion 

func (*StartPositionRequest) RecordingIdSinceVersion() uint16

func (*StartPositionRequest) SbeBlockLength 

func (*StartPositionRequest) SbeBlockLength() (blockLength uint16)

func (*StartPositionRequest) SbeSchemaId 

func (*StartPositionRequest) SbeSchemaId() (schemaId uint16)

func (*StartPositionRequest) SbeSchemaVersion 

func (*StartPositionRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*StartPositionRequest) SbeSemanticType 

func (*StartPositionRequest) SbeSemanticType() (semanticType []byte)

func (*StartPositionRequest) SbeTemplateId 

func (*StartPositionRequest) SbeTemplateId() (templateId uint16)

type StartRecordingRequest 

type StartRecordingRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	StreamId         int32
	SourceLocation   SourceLocationEnum
	Channel          []uint8
}

func (StartRecordingRequest) ChannelCharacterEncoding 

func (StartRecordingRequest) ChannelCharacterEncoding() string

func (*StartRecordingRequest) ChannelDeprecated 

func (*StartRecordingRequest) ChannelDeprecated() uint16

func (StartRecordingRequest) ChannelHeaderLength 

func (StartRecordingRequest) ChannelHeaderLength() uint64

func (*StartRecordingRequest) ChannelInActingVersion 

func (s *StartRecordingRequest) ChannelInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest) ChannelMetaAttribute 

func (*StartRecordingRequest) ChannelMetaAttribute(meta int) string

func (*StartRecordingRequest) ChannelSinceVersion 

func (*StartRecordingRequest) ChannelSinceVersion() uint16

func (*StartRecordingRequest) ControlSessionIdDeprecated 

func (*StartRecordingRequest) ControlSessionIdDeprecated() uint16

func (*StartRecordingRequest) ControlSessionIdId 

func (*StartRecordingRequest) ControlSessionIdId() uint16

func (*StartRecordingRequest) ControlSessionIdInActingVersion 

func (s *StartRecordingRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest) ControlSessionIdMaxValue 

func (*StartRecordingRequest) ControlSessionIdMaxValue() int64

func (*StartRecordingRequest) ControlSessionIdMetaAttribute 

func (*StartRecordingRequest) ControlSessionIdMetaAttribute(meta int) string

func (*StartRecordingRequest) ControlSessionIdMinValue 

func (*StartRecordingRequest) ControlSessionIdMinValue() int64

func (*StartRecordingRequest) ControlSessionIdNullValue 

func (*StartRecordingRequest) ControlSessionIdNullValue() int64

func (*StartRecordingRequest) ControlSessionIdSinceVersion 

func (*StartRecordingRequest) ControlSessionIdSinceVersion() uint16

func (*StartRecordingRequest) CorrelationIdDeprecated 

func (*StartRecordingRequest) CorrelationIdDeprecated() uint16

func (*StartRecordingRequest) CorrelationIdId 

func (*StartRecordingRequest) CorrelationIdId() uint16

func (*StartRecordingRequest) CorrelationIdInActingVersion 

func (s *StartRecordingRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest) CorrelationIdMaxValue 

func (*StartRecordingRequest) CorrelationIdMaxValue() int64

func (*StartRecordingRequest) CorrelationIdMetaAttribute 

func (*StartRecordingRequest) CorrelationIdMetaAttribute(meta int) string

func (*StartRecordingRequest) CorrelationIdMinValue 

func (*StartRecordingRequest) CorrelationIdMinValue() int64

func (*StartRecordingRequest) CorrelationIdNullValue 

func (*StartRecordingRequest) CorrelationIdNullValue() int64

func (*StartRecordingRequest) CorrelationIdSinceVersion 

func (*StartRecordingRequest) CorrelationIdSinceVersion() uint16

func (*StartRecordingRequest) Decode 

func (s *StartRecordingRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*StartRecordingRequest) Encode 

func (s *StartRecordingRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*StartRecordingRequest) RangeCheck 

func (s *StartRecordingRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*StartRecordingRequest) SbeBlockLength 

func (*StartRecordingRequest) SbeBlockLength() (blockLength uint16)

func (*StartRecordingRequest) SbeSchemaId 

func (*StartRecordingRequest) SbeSchemaId() (schemaId uint16)

func (*StartRecordingRequest) SbeSchemaVersion 

func (*StartRecordingRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*StartRecordingRequest) SbeSemanticType 

func (*StartRecordingRequest) SbeSemanticType() (semanticType []byte)

func (*StartRecordingRequest) SbeTemplateId 

func (*StartRecordingRequest) SbeTemplateId() (templateId uint16)

func (*StartRecordingRequest) SourceLocationDeprecated 

func (*StartRecordingRequest) SourceLocationDeprecated() uint16

func (*StartRecordingRequest) SourceLocationId 

func (*StartRecordingRequest) SourceLocationId() uint16

func (*StartRecordingRequest) SourceLocationInActingVersion 

func (s *StartRecordingRequest) SourceLocationInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest) SourceLocationMetaAttribute 

func (*StartRecordingRequest) SourceLocationMetaAttribute(meta int) string

func (*StartRecordingRequest) SourceLocationSinceVersion 

func (*StartRecordingRequest) SourceLocationSinceVersion() uint16

func (*StartRecordingRequest) StreamIdDeprecated 

func (*StartRecordingRequest) StreamIdDeprecated() uint16

func (*StartRecordingRequest) StreamIdId 

func (*StartRecordingRequest) StreamIdId() uint16

func (*StartRecordingRequest) StreamIdInActingVersion 

func (s *StartRecordingRequest) StreamIdInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest) StreamIdMaxValue 

func (*StartRecordingRequest) StreamIdMaxValue() int32

func (*StartRecordingRequest) StreamIdMetaAttribute 

func (*StartRecordingRequest) StreamIdMetaAttribute(meta int) string

func (*StartRecordingRequest) StreamIdMinValue 

func (*StartRecordingRequest) StreamIdMinValue() int32

func (*StartRecordingRequest) StreamIdNullValue 

func (*StartRecordingRequest) StreamIdNullValue() int32

func (*StartRecordingRequest) StreamIdSinceVersion 

func (*StartRecordingRequest) StreamIdSinceVersion() uint16

type StartRecordingRequest2 

type StartRecordingRequest2 struct {
	ControlSessionId int64
	CorrelationId    int64
	StreamId         int32
	SourceLocation   SourceLocationEnum
	AutoStop         BooleanTypeEnum
	Channel          []uint8
}

func (*StartRecordingRequest2) AutoStopDeprecated 

func (*StartRecordingRequest2) AutoStopDeprecated() uint16

func (*StartRecordingRequest2) AutoStopId 

func (*StartRecordingRequest2) AutoStopId() uint16

func (*StartRecordingRequest2) AutoStopInActingVersion 

func (s *StartRecordingRequest2) AutoStopInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest2) AutoStopMetaAttribute 

func (*StartRecordingRequest2) AutoStopMetaAttribute(meta int) string

func (*StartRecordingRequest2) AutoStopSinceVersion 

func (*StartRecordingRequest2) AutoStopSinceVersion() uint16

func (StartRecordingRequest2) ChannelCharacterEncoding 

func (StartRecordingRequest2) ChannelCharacterEncoding() string

func (*StartRecordingRequest2) ChannelDeprecated 

func (*StartRecordingRequest2) ChannelDeprecated() uint16

func (StartRecordingRequest2) ChannelHeaderLength 

func (StartRecordingRequest2) ChannelHeaderLength() uint64

func (*StartRecordingRequest2) ChannelInActingVersion 

func (s *StartRecordingRequest2) ChannelInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest2) ChannelMetaAttribute 

func (*StartRecordingRequest2) ChannelMetaAttribute(meta int) string

func (*StartRecordingRequest2) ChannelSinceVersion 

func (*StartRecordingRequest2) ChannelSinceVersion() uint16

func (*StartRecordingRequest2) ControlSessionIdDeprecated 

func (*StartRecordingRequest2) ControlSessionIdDeprecated() uint16

func (*StartRecordingRequest2) ControlSessionIdId 

func (*StartRecordingRequest2) ControlSessionIdId() uint16

func (*StartRecordingRequest2) ControlSessionIdInActingVersion 

func (s *StartRecordingRequest2) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest2) ControlSessionIdMaxValue 

func (*StartRecordingRequest2) ControlSessionIdMaxValue() int64

func (*StartRecordingRequest2) ControlSessionIdMetaAttribute 

func (*StartRecordingRequest2) ControlSessionIdMetaAttribute(meta int) string

func (*StartRecordingRequest2) ControlSessionIdMinValue 

func (*StartRecordingRequest2) ControlSessionIdMinValue() int64

func (*StartRecordingRequest2) ControlSessionIdNullValue 

func (*StartRecordingRequest2) ControlSessionIdNullValue() int64

func (*StartRecordingRequest2) ControlSessionIdSinceVersion 

func (*StartRecordingRequest2) ControlSessionIdSinceVersion() uint16

func (*StartRecordingRequest2) CorrelationIdDeprecated 

func (*StartRecordingRequest2) CorrelationIdDeprecated() uint16

func (*StartRecordingRequest2) CorrelationIdId 

func (*StartRecordingRequest2) CorrelationIdId() uint16

func (*StartRecordingRequest2) CorrelationIdInActingVersion 

func (s *StartRecordingRequest2) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest2) CorrelationIdMaxValue 

func (*StartRecordingRequest2) CorrelationIdMaxValue() int64

func (*StartRecordingRequest2) CorrelationIdMetaAttribute 

func (*StartRecordingRequest2) CorrelationIdMetaAttribute(meta int) string

func (*StartRecordingRequest2) CorrelationIdMinValue 

func (*StartRecordingRequest2) CorrelationIdMinValue() int64

func (*StartRecordingRequest2) CorrelationIdNullValue 

func (*StartRecordingRequest2) CorrelationIdNullValue() int64

func (*StartRecordingRequest2) CorrelationIdSinceVersion 

func (*StartRecordingRequest2) CorrelationIdSinceVersion() uint16

func (*StartRecordingRequest2) Decode 

func (s *StartRecordingRequest2) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*StartRecordingRequest2) Encode 

func (s *StartRecordingRequest2) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*StartRecordingRequest2) RangeCheck 

func (s *StartRecordingRequest2) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*StartRecordingRequest2) SbeBlockLength 

func (*StartRecordingRequest2) SbeBlockLength() (blockLength uint16)

func (*StartRecordingRequest2) SbeSchemaId 

func (*StartRecordingRequest2) SbeSchemaId() (schemaId uint16)

func (*StartRecordingRequest2) SbeSchemaVersion 

func (*StartRecordingRequest2) SbeSchemaVersion() (schemaVersion uint16)

func (*StartRecordingRequest2) SbeSemanticType 

func (*StartRecordingRequest2) SbeSemanticType() (semanticType []byte)

func (*StartRecordingRequest2) SbeTemplateId 

func (*StartRecordingRequest2) SbeTemplateId() (templateId uint16)

func (*StartRecordingRequest2) SourceLocationDeprecated 

func (*StartRecordingRequest2) SourceLocationDeprecated() uint16

func (*StartRecordingRequest2) SourceLocationId 

func (*StartRecordingRequest2) SourceLocationId() uint16

func (*StartRecordingRequest2) SourceLocationInActingVersion 

func (s *StartRecordingRequest2) SourceLocationInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest2) SourceLocationMetaAttribute 

func (*StartRecordingRequest2) SourceLocationMetaAttribute(meta int) string

func (*StartRecordingRequest2) SourceLocationSinceVersion 

func (*StartRecordingRequest2) SourceLocationSinceVersion() uint16

func (*StartRecordingRequest2) StreamIdDeprecated 

func (*StartRecordingRequest2) StreamIdDeprecated() uint16

func (*StartRecordingRequest2) StreamIdId 

func (*StartRecordingRequest2) StreamIdId() uint16

func (*StartRecordingRequest2) StreamIdInActingVersion 

func (s *StartRecordingRequest2) StreamIdInActingVersion(actingVersion uint16) bool

func (*StartRecordingRequest2) StreamIdMaxValue 

func (*StartRecordingRequest2) StreamIdMaxValue() int32

func (*StartRecordingRequest2) StreamIdMetaAttribute 

func (*StartRecordingRequest2) StreamIdMetaAttribute(meta int) string

func (*StartRecordingRequest2) StreamIdMinValue 

func (*StartRecordingRequest2) StreamIdMinValue() int32

func (*StartRecordingRequest2) StreamIdNullValue 

func (*StartRecordingRequest2) StreamIdNullValue() int32

func (*StartRecordingRequest2) StreamIdSinceVersion 

func (*StartRecordingRequest2) StreamIdSinceVersion() uint16

type StopAllReplaysRequest 

type StopAllReplaysRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
}

func (*StopAllReplaysRequest) ControlSessionIdDeprecated 

func (*StopAllReplaysRequest) ControlSessionIdDeprecated() uint16

func (*StopAllReplaysRequest) ControlSessionIdId 

func (*StopAllReplaysRequest) ControlSessionIdId() uint16

func (*StopAllReplaysRequest) ControlSessionIdInActingVersion 

func (s *StopAllReplaysRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*StopAllReplaysRequest) ControlSessionIdMaxValue 

func (*StopAllReplaysRequest) ControlSessionIdMaxValue() int64

func (*StopAllReplaysRequest) ControlSessionIdMetaAttribute 

func (*StopAllReplaysRequest) ControlSessionIdMetaAttribute(meta int) string

func (*StopAllReplaysRequest) ControlSessionIdMinValue 

func (*StopAllReplaysRequest) ControlSessionIdMinValue() int64

func (*StopAllReplaysRequest) ControlSessionIdNullValue 

func (*StopAllReplaysRequest) ControlSessionIdNullValue() int64

func (*StopAllReplaysRequest) ControlSessionIdSinceVersion 

func (*StopAllReplaysRequest) ControlSessionIdSinceVersion() uint16

func (*StopAllReplaysRequest) CorrelationIdDeprecated 

func (*StopAllReplaysRequest) CorrelationIdDeprecated() uint16

func (*StopAllReplaysRequest) CorrelationIdId 

func (*StopAllReplaysRequest) CorrelationIdId() uint16

func (*StopAllReplaysRequest) CorrelationIdInActingVersion 

func (s *StopAllReplaysRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*StopAllReplaysRequest) CorrelationIdMaxValue 

func (*StopAllReplaysRequest) CorrelationIdMaxValue() int64

func (*StopAllReplaysRequest) CorrelationIdMetaAttribute 

func (*StopAllReplaysRequest) CorrelationIdMetaAttribute(meta int) string

func (*StopAllReplaysRequest) CorrelationIdMinValue 

func (*StopAllReplaysRequest) CorrelationIdMinValue() int64

func (*StopAllReplaysRequest) CorrelationIdNullValue 

func (*StopAllReplaysRequest) CorrelationIdNullValue() int64

func (*StopAllReplaysRequest) CorrelationIdSinceVersion 

func (*StopAllReplaysRequest) CorrelationIdSinceVersion() uint16

func (*StopAllReplaysRequest) Decode 

func (s *StopAllReplaysRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*StopAllReplaysRequest) Encode 

func (s *StopAllReplaysRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*StopAllReplaysRequest) RangeCheck 

func (s *StopAllReplaysRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*StopAllReplaysRequest) RecordingIdDeprecated 

func (*StopAllReplaysRequest) RecordingIdDeprecated() uint16

func (*StopAllReplaysRequest) RecordingIdId 

func (*StopAllReplaysRequest) RecordingIdId() uint16

func (*StopAllReplaysRequest) RecordingIdInActingVersion 

func (s *StopAllReplaysRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*StopAllReplaysRequest) RecordingIdMaxValue 

func (*StopAllReplaysRequest) RecordingIdMaxValue() int64

func (*StopAllReplaysRequest) RecordingIdMetaAttribute 

func (*StopAllReplaysRequest) RecordingIdMetaAttribute(meta int) string

func (*StopAllReplaysRequest) RecordingIdMinValue 

func (*StopAllReplaysRequest) RecordingIdMinValue() int64

func (*StopAllReplaysRequest) RecordingIdNullValue 

func (*StopAllReplaysRequest) RecordingIdNullValue() int64

func (*StopAllReplaysRequest) RecordingIdSinceVersion 

func (*StopAllReplaysRequest) RecordingIdSinceVersion() uint16

func (*StopAllReplaysRequest) SbeBlockLength 

func (*StopAllReplaysRequest) SbeBlockLength() (blockLength uint16)

func (*StopAllReplaysRequest) SbeSchemaId 

func (*StopAllReplaysRequest) SbeSchemaId() (schemaId uint16)

func (*StopAllReplaysRequest) SbeSchemaVersion 

func (*StopAllReplaysRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*StopAllReplaysRequest) SbeSemanticType 

func (*StopAllReplaysRequest) SbeSemanticType() (semanticType []byte)

func (*StopAllReplaysRequest) SbeTemplateId 

func (*StopAllReplaysRequest) SbeTemplateId() (templateId uint16)

type StopPositionRequest 

type StopPositionRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
}

func (*StopPositionRequest) ControlSessionIdDeprecated 

func (*StopPositionRequest) ControlSessionIdDeprecated() uint16

func (*StopPositionRequest) ControlSessionIdId 

func (*StopPositionRequest) ControlSessionIdId() uint16

func (*StopPositionRequest) ControlSessionIdInActingVersion 

func (s *StopPositionRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*StopPositionRequest) ControlSessionIdMaxValue 

func (*StopPositionRequest) ControlSessionIdMaxValue() int64

func (*StopPositionRequest) ControlSessionIdMetaAttribute 

func (*StopPositionRequest) ControlSessionIdMetaAttribute(meta int) string

func (*StopPositionRequest) ControlSessionIdMinValue 

func (*StopPositionRequest) ControlSessionIdMinValue() int64

func (*StopPositionRequest) ControlSessionIdNullValue 

func (*StopPositionRequest) ControlSessionIdNullValue() int64

func (*StopPositionRequest) ControlSessionIdSinceVersion 

func (*StopPositionRequest) ControlSessionIdSinceVersion() uint16

func (*StopPositionRequest) CorrelationIdDeprecated 

func (*StopPositionRequest) CorrelationIdDeprecated() uint16

func (*StopPositionRequest) CorrelationIdId 

func (*StopPositionRequest) CorrelationIdId() uint16

func (*StopPositionRequest) CorrelationIdInActingVersion 

func (s *StopPositionRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*StopPositionRequest) CorrelationIdMaxValue 

func (*StopPositionRequest) CorrelationIdMaxValue() int64

func (*StopPositionRequest) CorrelationIdMetaAttribute 

func (*StopPositionRequest) CorrelationIdMetaAttribute(meta int) string

func (*StopPositionRequest) CorrelationIdMinValue 

func (*StopPositionRequest) CorrelationIdMinValue() int64

func (*StopPositionRequest) CorrelationIdNullValue 

func (*StopPositionRequest) CorrelationIdNullValue() int64

func (*StopPositionRequest) CorrelationIdSinceVersion 

func (*StopPositionRequest) CorrelationIdSinceVersion() uint16

func (*StopPositionRequest) Decode 

func (s *StopPositionRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*StopPositionRequest) Encode 

func (s *StopPositionRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*StopPositionRequest) RangeCheck 

func (s *StopPositionRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*StopPositionRequest) RecordingIdDeprecated 

func (*StopPositionRequest) RecordingIdDeprecated() uint16

func (*StopPositionRequest) RecordingIdId 

func (*StopPositionRequest) RecordingIdId() uint16

func (*StopPositionRequest) RecordingIdInActingVersion 

func (s *StopPositionRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*StopPositionRequest) RecordingIdMaxValue 

func (*StopPositionRequest) RecordingIdMaxValue() int64

func (*StopPositionRequest) RecordingIdMetaAttribute 

func (*StopPositionRequest) RecordingIdMetaAttribute(meta int) string

func (*StopPositionRequest) RecordingIdMinValue 

func (*StopPositionRequest) RecordingIdMinValue() int64

func (*StopPositionRequest) RecordingIdNullValue 

func (*StopPositionRequest) RecordingIdNullValue() int64

func (*StopPositionRequest) RecordingIdSinceVersion 

func (*StopPositionRequest) RecordingIdSinceVersion() uint16

func (*StopPositionRequest) SbeBlockLength 

func (*StopPositionRequest) SbeBlockLength() (blockLength uint16)

func (*StopPositionRequest) SbeSchemaId 

func (*StopPositionRequest) SbeSchemaId() (schemaId uint16)

func (*StopPositionRequest) SbeSchemaVersion 

func (*StopPositionRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*StopPositionRequest) SbeSemanticType 

func (*StopPositionRequest) SbeSemanticType() (semanticType []byte)

func (*StopPositionRequest) SbeTemplateId 

func (*StopPositionRequest) SbeTemplateId() (templateId uint16)

type StopRecordingByIdentityRequest 

type StopRecordingByIdentityRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
}

func (*StopRecordingByIdentityRequest) ControlSessionIdDeprecated 

func (*StopRecordingByIdentityRequest) ControlSessionIdDeprecated() uint16

func (*StopRecordingByIdentityRequest) ControlSessionIdId 

func (*StopRecordingByIdentityRequest) ControlSessionIdId() uint16

func (*StopRecordingByIdentityRequest) ControlSessionIdInActingVersion 

func (s *StopRecordingByIdentityRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*StopRecordingByIdentityRequest) ControlSessionIdMaxValue 

func (*StopRecordingByIdentityRequest) ControlSessionIdMaxValue() int64

func (*StopRecordingByIdentityRequest) ControlSessionIdMetaAttribute 

func (*StopRecordingByIdentityRequest) ControlSessionIdMetaAttribute(meta int) string

func (*StopRecordingByIdentityRequest) ControlSessionIdMinValue 

func (*StopRecordingByIdentityRequest) ControlSessionIdMinValue() int64

func (*StopRecordingByIdentityRequest) ControlSessionIdNullValue 

func (*StopRecordingByIdentityRequest) ControlSessionIdNullValue() int64

func (*StopRecordingByIdentityRequest) ControlSessionIdSinceVersion 

func (*StopRecordingByIdentityRequest) ControlSessionIdSinceVersion() uint16

func (*StopRecordingByIdentityRequest) CorrelationIdDeprecated 

func (*StopRecordingByIdentityRequest) CorrelationIdDeprecated() uint16

func (*StopRecordingByIdentityRequest) CorrelationIdId 

func (*StopRecordingByIdentityRequest) CorrelationIdId() uint16

func (*StopRecordingByIdentityRequest) CorrelationIdInActingVersion 

func (s *StopRecordingByIdentityRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*StopRecordingByIdentityRequest) CorrelationIdMaxValue 

func (*StopRecordingByIdentityRequest) CorrelationIdMaxValue() int64

func (*StopRecordingByIdentityRequest) CorrelationIdMetaAttribute 

func (*StopRecordingByIdentityRequest) CorrelationIdMetaAttribute(meta int) string

func (*StopRecordingByIdentityRequest) CorrelationIdMinValue 

func (*StopRecordingByIdentityRequest) CorrelationIdMinValue() int64

func (*StopRecordingByIdentityRequest) CorrelationIdNullValue 

func (*StopRecordingByIdentityRequest) CorrelationIdNullValue() int64

func (*StopRecordingByIdentityRequest) CorrelationIdSinceVersion 

func (*StopRecordingByIdentityRequest) CorrelationIdSinceVersion() uint16

func (*StopRecordingByIdentityRequest) Decode 

func (s *StopRecordingByIdentityRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*StopRecordingByIdentityRequest) Encode 

func (s *StopRecordingByIdentityRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*StopRecordingByIdentityRequest) RangeCheck 

func (s *StopRecordingByIdentityRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*StopRecordingByIdentityRequest) RecordingIdDeprecated 

func (*StopRecordingByIdentityRequest) RecordingIdDeprecated() uint16

func (*StopRecordingByIdentityRequest) RecordingIdId 

func (*StopRecordingByIdentityRequest) RecordingIdId() uint16

func (*StopRecordingByIdentityRequest) RecordingIdInActingVersion 

func (s *StopRecordingByIdentityRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*StopRecordingByIdentityRequest) RecordingIdMaxValue 

func (*StopRecordingByIdentityRequest) RecordingIdMaxValue() int64

func (*StopRecordingByIdentityRequest) RecordingIdMetaAttribute 

func (*StopRecordingByIdentityRequest) RecordingIdMetaAttribute(meta int) string

func (*StopRecordingByIdentityRequest) RecordingIdMinValue 

func (*StopRecordingByIdentityRequest) RecordingIdMinValue() int64

func (*StopRecordingByIdentityRequest) RecordingIdNullValue 

func (*StopRecordingByIdentityRequest) RecordingIdNullValue() int64

func (*StopRecordingByIdentityRequest) RecordingIdSinceVersion 

func (*StopRecordingByIdentityRequest) RecordingIdSinceVersion() uint16

func (*StopRecordingByIdentityRequest) SbeBlockLength 

func (*StopRecordingByIdentityRequest) SbeBlockLength() (blockLength uint16)

func (*StopRecordingByIdentityRequest) SbeSchemaId 

func (*StopRecordingByIdentityRequest) SbeSchemaId() (schemaId uint16)

func (*StopRecordingByIdentityRequest) SbeSchemaVersion 

func (*StopRecordingByIdentityRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*StopRecordingByIdentityRequest) SbeSemanticType 

func (*StopRecordingByIdentityRequest) SbeSemanticType() (semanticType []byte)

func (*StopRecordingByIdentityRequest) SbeTemplateId 

func (*StopRecordingByIdentityRequest) SbeTemplateId() (templateId uint16)

type StopRecordingRequest 

type StopRecordingRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	StreamId         int32
	Channel          []uint8
}

func (StopRecordingRequest) ChannelCharacterEncoding 

func (StopRecordingRequest) ChannelCharacterEncoding() string

func (*StopRecordingRequest) ChannelDeprecated 

func (*StopRecordingRequest) ChannelDeprecated() uint16

func (StopRecordingRequest) ChannelHeaderLength 

func (StopRecordingRequest) ChannelHeaderLength() uint64

func (*StopRecordingRequest) ChannelInActingVersion 

func (s *StopRecordingRequest) ChannelInActingVersion(actingVersion uint16) bool

func (*StopRecordingRequest) ChannelMetaAttribute 

func (*StopRecordingRequest) ChannelMetaAttribute(meta int) string

func (*StopRecordingRequest) ChannelSinceVersion 

func (*StopRecordingRequest) ChannelSinceVersion() uint16

func (*StopRecordingRequest) ControlSessionIdDeprecated 

func (*StopRecordingRequest) ControlSessionIdDeprecated() uint16

func (*StopRecordingRequest) ControlSessionIdId 

func (*StopRecordingRequest) ControlSessionIdId() uint16

func (*StopRecordingRequest) ControlSessionIdInActingVersion 

func (s *StopRecordingRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*StopRecordingRequest) ControlSessionIdMaxValue 

func (*StopRecordingRequest) ControlSessionIdMaxValue() int64

func (*StopRecordingRequest) ControlSessionIdMetaAttribute 

func (*StopRecordingRequest) ControlSessionIdMetaAttribute(meta int) string

func (*StopRecordingRequest) ControlSessionIdMinValue 

func (*StopRecordingRequest) ControlSessionIdMinValue() int64

func (*StopRecordingRequest) ControlSessionIdNullValue 

func (*StopRecordingRequest) ControlSessionIdNullValue() int64

func (*StopRecordingRequest) ControlSessionIdSinceVersion 

func (*StopRecordingRequest) ControlSessionIdSinceVersion() uint16

func (*StopRecordingRequest) CorrelationIdDeprecated 

func (*StopRecordingRequest) CorrelationIdDeprecated() uint16

func (*StopRecordingRequest) CorrelationIdId 

func (*StopRecordingRequest) CorrelationIdId() uint16

func (*StopRecordingRequest) CorrelationIdInActingVersion 

func (s *StopRecordingRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*StopRecordingRequest) CorrelationIdMaxValue 

func (*StopRecordingRequest) CorrelationIdMaxValue() int64

func (*StopRecordingRequest) CorrelationIdMetaAttribute 

func (*StopRecordingRequest) CorrelationIdMetaAttribute(meta int) string

func (*StopRecordingRequest) CorrelationIdMinValue 

func (*StopRecordingRequest) CorrelationIdMinValue() int64

func (*StopRecordingRequest) CorrelationIdNullValue 

func (*StopRecordingRequest) CorrelationIdNullValue() int64

func (*StopRecordingRequest) CorrelationIdSinceVersion 

func (*StopRecordingRequest) CorrelationIdSinceVersion() uint16

func (*StopRecordingRequest) Decode 

func (s *StopRecordingRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*StopRecordingRequest) Encode 

func (s *StopRecordingRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*StopRecordingRequest) RangeCheck 

func (s *StopRecordingRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*StopRecordingRequest) SbeBlockLength 

func (*StopRecordingRequest) SbeBlockLength() (blockLength uint16)

func (*StopRecordingRequest) SbeSchemaId 

func (*StopRecordingRequest) SbeSchemaId() (schemaId uint16)

func (*StopRecordingRequest) SbeSchemaVersion 

func (*StopRecordingRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*StopRecordingRequest) SbeSemanticType 

func (*StopRecordingRequest) SbeSemanticType() (semanticType []byte)

func (*StopRecordingRequest) SbeTemplateId 

func (*StopRecordingRequest) SbeTemplateId() (templateId uint16)

func (*StopRecordingRequest) StreamIdDeprecated 

func (*StopRecordingRequest) StreamIdDeprecated() uint16

func (*StopRecordingRequest) StreamIdId 

func (*StopRecordingRequest) StreamIdId() uint16

func (*StopRecordingRequest) StreamIdInActingVersion 

func (s *StopRecordingRequest) StreamIdInActingVersion(actingVersion uint16) bool

func (*StopRecordingRequest) StreamIdMaxValue 

func (*StopRecordingRequest) StreamIdMaxValue() int32

func (*StopRecordingRequest) StreamIdMetaAttribute 

func (*StopRecordingRequest) StreamIdMetaAttribute(meta int) string

func (*StopRecordingRequest) StreamIdMinValue 

func (*StopRecordingRequest) StreamIdMinValue() int32

func (*StopRecordingRequest) StreamIdNullValue 

func (*StopRecordingRequest) StreamIdNullValue() int32

func (*StopRecordingRequest) StreamIdSinceVersion 

func (*StopRecordingRequest) StreamIdSinceVersion() uint16

type StopRecordingSubscriptionRequest 

type StopRecordingSubscriptionRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	SubscriptionId   int64
}

func (*StopRecordingSubscriptionRequest) ControlSessionIdDeprecated 

func (*StopRecordingSubscriptionRequest) ControlSessionIdDeprecated() uint16

func (*StopRecordingSubscriptionRequest) ControlSessionIdId 

func (*StopRecordingSubscriptionRequest) ControlSessionIdId() uint16

func (*StopRecordingSubscriptionRequest) ControlSessionIdInActingVersion 

func (s *StopRecordingSubscriptionRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*StopRecordingSubscriptionRequest) ControlSessionIdMaxValue 

func (*StopRecordingSubscriptionRequest) ControlSessionIdMaxValue() int64

func (*StopRecordingSubscriptionRequest) ControlSessionIdMetaAttribute 

func (*StopRecordingSubscriptionRequest) ControlSessionIdMetaAttribute(meta int) string

func (*StopRecordingSubscriptionRequest) ControlSessionIdMinValue 

func (*StopRecordingSubscriptionRequest) ControlSessionIdMinValue() int64

func (*StopRecordingSubscriptionRequest) ControlSessionIdNullValue 

func (*StopRecordingSubscriptionRequest) ControlSessionIdNullValue() int64

func (*StopRecordingSubscriptionRequest) ControlSessionIdSinceVersion 

func (*StopRecordingSubscriptionRequest) ControlSessionIdSinceVersion() uint16

func (*StopRecordingSubscriptionRequest) CorrelationIdDeprecated 

func (*StopRecordingSubscriptionRequest) CorrelationIdDeprecated() uint16

func (*StopRecordingSubscriptionRequest) CorrelationIdId 

func (*StopRecordingSubscriptionRequest) CorrelationIdId() uint16

func (*StopRecordingSubscriptionRequest) CorrelationIdInActingVersion 

func (s *StopRecordingSubscriptionRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*StopRecordingSubscriptionRequest) CorrelationIdMaxValue 

func (*StopRecordingSubscriptionRequest) CorrelationIdMaxValue() int64

func (*StopRecordingSubscriptionRequest) CorrelationIdMetaAttribute 

func (*StopRecordingSubscriptionRequest) CorrelationIdMetaAttribute(meta int) string

func (*StopRecordingSubscriptionRequest) CorrelationIdMinValue 

func (*StopRecordingSubscriptionRequest) CorrelationIdMinValue() int64

func (*StopRecordingSubscriptionRequest) CorrelationIdNullValue 

func (*StopRecordingSubscriptionRequest) CorrelationIdNullValue() int64

func (*StopRecordingSubscriptionRequest) CorrelationIdSinceVersion 

func (*StopRecordingSubscriptionRequest) CorrelationIdSinceVersion() uint16

func (*StopRecordingSubscriptionRequest) Decode 

func (s *StopRecordingSubscriptionRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*StopRecordingSubscriptionRequest) Encode 

func (s *StopRecordingSubscriptionRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*StopRecordingSubscriptionRequest) RangeCheck 

func (s *StopRecordingSubscriptionRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*StopRecordingSubscriptionRequest) SbeBlockLength 

func (*StopRecordingSubscriptionRequest) SbeBlockLength() (blockLength uint16)

func (*StopRecordingSubscriptionRequest) SbeSchemaId 

func (*StopRecordingSubscriptionRequest) SbeSchemaId() (schemaId uint16)

func (*StopRecordingSubscriptionRequest) SbeSchemaVersion 

func (*StopRecordingSubscriptionRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*StopRecordingSubscriptionRequest) SbeSemanticType 

func (*StopRecordingSubscriptionRequest) SbeSemanticType() (semanticType []byte)

func (*StopRecordingSubscriptionRequest) SbeTemplateId 

func (*StopRecordingSubscriptionRequest) SbeTemplateId() (templateId uint16)

func (*StopRecordingSubscriptionRequest) SubscriptionIdDeprecated 

func (*StopRecordingSubscriptionRequest) SubscriptionIdDeprecated() uint16

func (*StopRecordingSubscriptionRequest) SubscriptionIdId 

func (*StopRecordingSubscriptionRequest) SubscriptionIdId() uint16

func (*StopRecordingSubscriptionRequest) SubscriptionIdInActingVersion 

func (s *StopRecordingSubscriptionRequest) SubscriptionIdInActingVersion(actingVersion uint16) bool

func (*StopRecordingSubscriptionRequest) SubscriptionIdMaxValue 

func (*StopRecordingSubscriptionRequest) SubscriptionIdMaxValue() int64

func (*StopRecordingSubscriptionRequest) SubscriptionIdMetaAttribute 

func (*StopRecordingSubscriptionRequest) SubscriptionIdMetaAttribute(meta int) string

func (*StopRecordingSubscriptionRequest) SubscriptionIdMinValue 

func (*StopRecordingSubscriptionRequest) SubscriptionIdMinValue() int64

func (*StopRecordingSubscriptionRequest) SubscriptionIdNullValue 

func (*StopRecordingSubscriptionRequest) SubscriptionIdNullValue() int64

func (*StopRecordingSubscriptionRequest) SubscriptionIdSinceVersion 

func (*StopRecordingSubscriptionRequest) SubscriptionIdSinceVersion() uint16

type StopReplayRequest 

type StopReplayRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	ReplaySessionId  int64
}

func (*StopReplayRequest) ControlSessionIdDeprecated 

func (*StopReplayRequest) ControlSessionIdDeprecated() uint16

func (*StopReplayRequest) ControlSessionIdId 

func (*StopReplayRequest) ControlSessionIdId() uint16

func (*StopReplayRequest) ControlSessionIdInActingVersion 

func (s *StopReplayRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*StopReplayRequest) ControlSessionIdMaxValue 

func (*StopReplayRequest) ControlSessionIdMaxValue() int64

func (*StopReplayRequest) ControlSessionIdMetaAttribute 

func (*StopReplayRequest) ControlSessionIdMetaAttribute(meta int) string

func (*StopReplayRequest) ControlSessionIdMinValue 

func (*StopReplayRequest) ControlSessionIdMinValue() int64

func (*StopReplayRequest) ControlSessionIdNullValue 

func (*StopReplayRequest) ControlSessionIdNullValue() int64

func (*StopReplayRequest) ControlSessionIdSinceVersion 

func (*StopReplayRequest) ControlSessionIdSinceVersion() uint16

func (*StopReplayRequest) CorrelationIdDeprecated 

func (*StopReplayRequest) CorrelationIdDeprecated() uint16

func (*StopReplayRequest) CorrelationIdId 

func (*StopReplayRequest) CorrelationIdId() uint16

func (*StopReplayRequest) CorrelationIdInActingVersion 

func (s *StopReplayRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*StopReplayRequest) CorrelationIdMaxValue 

func (*StopReplayRequest) CorrelationIdMaxValue() int64

func (*StopReplayRequest) CorrelationIdMetaAttribute 

func (*StopReplayRequest) CorrelationIdMetaAttribute(meta int) string

func (*StopReplayRequest) CorrelationIdMinValue 

func (*StopReplayRequest) CorrelationIdMinValue() int64

func (*StopReplayRequest) CorrelationIdNullValue 

func (*StopReplayRequest) CorrelationIdNullValue() int64

func (*StopReplayRequest) CorrelationIdSinceVersion 

func (*StopReplayRequest) CorrelationIdSinceVersion() uint16

func (*StopReplayRequest) Decode 

func (s *StopReplayRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*StopReplayRequest) Encode 

func (s *StopReplayRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*StopReplayRequest) RangeCheck 

func (s *StopReplayRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*StopReplayRequest) ReplaySessionIdDeprecated 

func (*StopReplayRequest) ReplaySessionIdDeprecated() uint16

func (*StopReplayRequest) ReplaySessionIdId 

func (*StopReplayRequest) ReplaySessionIdId() uint16

func (*StopReplayRequest) ReplaySessionIdInActingVersion 

func (s *StopReplayRequest) ReplaySessionIdInActingVersion(actingVersion uint16) bool

func (*StopReplayRequest) ReplaySessionIdMaxValue 

func (*StopReplayRequest) ReplaySessionIdMaxValue() int64

func (*StopReplayRequest) ReplaySessionIdMetaAttribute 

func (*StopReplayRequest) ReplaySessionIdMetaAttribute(meta int) string

func (*StopReplayRequest) ReplaySessionIdMinValue 

func (*StopReplayRequest) ReplaySessionIdMinValue() int64

func (*StopReplayRequest) ReplaySessionIdNullValue 

func (*StopReplayRequest) ReplaySessionIdNullValue() int64

func (*StopReplayRequest) ReplaySessionIdSinceVersion 

func (*StopReplayRequest) ReplaySessionIdSinceVersion() uint16

func (*StopReplayRequest) SbeBlockLength 

func (*StopReplayRequest) SbeBlockLength() (blockLength uint16)

func (*StopReplayRequest) SbeSchemaId 

func (*StopReplayRequest) SbeSchemaId() (schemaId uint16)

func (*StopReplayRequest) SbeSchemaVersion 

func (*StopReplayRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*StopReplayRequest) SbeSemanticType 

func (*StopReplayRequest) SbeSemanticType() (semanticType []byte)

func (*StopReplayRequest) SbeTemplateId 

func (*StopReplayRequest) SbeTemplateId() (templateId uint16)

type StopReplicationRequest 

type StopReplicationRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	ReplicationId    int64
}

func (*StopReplicationRequest) ControlSessionIdDeprecated 

func (*StopReplicationRequest) ControlSessionIdDeprecated() uint16

func (*StopReplicationRequest) ControlSessionIdId 

func (*StopReplicationRequest) ControlSessionIdId() uint16

func (*StopReplicationRequest) ControlSessionIdInActingVersion 

func (s *StopReplicationRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*StopReplicationRequest) ControlSessionIdMaxValue 

func (*StopReplicationRequest) ControlSessionIdMaxValue() int64

func (*StopReplicationRequest) ControlSessionIdMetaAttribute 

func (*StopReplicationRequest) ControlSessionIdMetaAttribute(meta int) string

func (*StopReplicationRequest) ControlSessionIdMinValue 

func (*StopReplicationRequest) ControlSessionIdMinValue() int64

func (*StopReplicationRequest) ControlSessionIdNullValue 

func (*StopReplicationRequest) ControlSessionIdNullValue() int64

func (*StopReplicationRequest) ControlSessionIdSinceVersion 

func (*StopReplicationRequest) ControlSessionIdSinceVersion() uint16

func (*StopReplicationRequest) CorrelationIdDeprecated 

func (*StopReplicationRequest) CorrelationIdDeprecated() uint16

func (*StopReplicationRequest) CorrelationIdId 

func (*StopReplicationRequest) CorrelationIdId() uint16

func (*StopReplicationRequest) CorrelationIdInActingVersion 

func (s *StopReplicationRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*StopReplicationRequest) CorrelationIdMaxValue 

func (*StopReplicationRequest) CorrelationIdMaxValue() int64

func (*StopReplicationRequest) CorrelationIdMetaAttribute 

func (*StopReplicationRequest) CorrelationIdMetaAttribute(meta int) string

func (*StopReplicationRequest) CorrelationIdMinValue 

func (*StopReplicationRequest) CorrelationIdMinValue() int64

func (*StopReplicationRequest) CorrelationIdNullValue 

func (*StopReplicationRequest) CorrelationIdNullValue() int64

func (*StopReplicationRequest) CorrelationIdSinceVersion 

func (*StopReplicationRequest) CorrelationIdSinceVersion() uint16

func (*StopReplicationRequest) Decode 

func (s *StopReplicationRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*StopReplicationRequest) Encode 

func (s *StopReplicationRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*StopReplicationRequest) RangeCheck 

func (s *StopReplicationRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*StopReplicationRequest) ReplicationIdDeprecated 

func (*StopReplicationRequest) ReplicationIdDeprecated() uint16

func (*StopReplicationRequest) ReplicationIdId 

func (*StopReplicationRequest) ReplicationIdId() uint16

func (*StopReplicationRequest) ReplicationIdInActingVersion 

func (s *StopReplicationRequest) ReplicationIdInActingVersion(actingVersion uint16) bool

func (*StopReplicationRequest) ReplicationIdMaxValue 

func (*StopReplicationRequest) ReplicationIdMaxValue() int64

func (*StopReplicationRequest) ReplicationIdMetaAttribute 

func (*StopReplicationRequest) ReplicationIdMetaAttribute(meta int) string

func (*StopReplicationRequest) ReplicationIdMinValue 

func (*StopReplicationRequest) ReplicationIdMinValue() int64

func (*StopReplicationRequest) ReplicationIdNullValue 

func (*StopReplicationRequest) ReplicationIdNullValue() int64

func (*StopReplicationRequest) ReplicationIdSinceVersion 

func (*StopReplicationRequest) ReplicationIdSinceVersion() uint16

func (*StopReplicationRequest) SbeBlockLength 

func (*StopReplicationRequest) SbeBlockLength() (blockLength uint16)

func (*StopReplicationRequest) SbeSchemaId 

func (*StopReplicationRequest) SbeSchemaId() (schemaId uint16)

func (*StopReplicationRequest) SbeSchemaVersion 

func (*StopReplicationRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*StopReplicationRequest) SbeSemanticType 

func (*StopReplicationRequest) SbeSemanticType() (semanticType []byte)

func (*StopReplicationRequest) SbeTemplateId 

func (*StopReplicationRequest) SbeTemplateId() (templateId uint16)

type TaggedReplicateRequest 

type TaggedReplicateRequest struct {
	ControlSessionId   int64
	CorrelationId      int64
	SrcRecordingId     int64
	DstRecordingId     int64
	ChannelTagId       int64
	SubscriptionTagId  int64
	SrcControlStreamId int32
	SrcControlChannel  []uint8
	LiveDestination    []uint8
}

func (*TaggedReplicateRequest) ChannelTagIdDeprecated 

func (*TaggedReplicateRequest) ChannelTagIdDeprecated() uint16

func (*TaggedReplicateRequest) ChannelTagIdId 

func (*TaggedReplicateRequest) ChannelTagIdId() uint16

func (*TaggedReplicateRequest) ChannelTagIdInActingVersion 

func (t *TaggedReplicateRequest) ChannelTagIdInActingVersion(actingVersion uint16) bool

func (*TaggedReplicateRequest) ChannelTagIdMaxValue 

func (*TaggedReplicateRequest) ChannelTagIdMaxValue() int64

func (*TaggedReplicateRequest) ChannelTagIdMetaAttribute 

func (*TaggedReplicateRequest) ChannelTagIdMetaAttribute(meta int) string

func (*TaggedReplicateRequest) ChannelTagIdMinValue 

func (*TaggedReplicateRequest) ChannelTagIdMinValue() int64

func (*TaggedReplicateRequest) ChannelTagIdNullValue 

func (*TaggedReplicateRequest) ChannelTagIdNullValue() int64

func (*TaggedReplicateRequest) ChannelTagIdSinceVersion 

func (*TaggedReplicateRequest) ChannelTagIdSinceVersion() uint16

func (*TaggedReplicateRequest) ControlSessionIdDeprecated 

func (*TaggedReplicateRequest) ControlSessionIdDeprecated() uint16

func (*TaggedReplicateRequest) ControlSessionIdId 

func (*TaggedReplicateRequest) ControlSessionIdId() uint16

func (*TaggedReplicateRequest) ControlSessionIdInActingVersion 

func (t *TaggedReplicateRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*TaggedReplicateRequest) ControlSessionIdMaxValue 

func (*TaggedReplicateRequest) ControlSessionIdMaxValue() int64

func (*TaggedReplicateRequest) ControlSessionIdMetaAttribute 

func (*TaggedReplicateRequest) ControlSessionIdMetaAttribute(meta int) string

func (*TaggedReplicateRequest) ControlSessionIdMinValue 

func (*TaggedReplicateRequest) ControlSessionIdMinValue() int64

func (*TaggedReplicateRequest) ControlSessionIdNullValue 

func (*TaggedReplicateRequest) ControlSessionIdNullValue() int64

func (*TaggedReplicateRequest) ControlSessionIdSinceVersion 

func (*TaggedReplicateRequest) ControlSessionIdSinceVersion() uint16

func (*TaggedReplicateRequest) CorrelationIdDeprecated 

func (*TaggedReplicateRequest) CorrelationIdDeprecated() uint16

func (*TaggedReplicateRequest) CorrelationIdId 

func (*TaggedReplicateRequest) CorrelationIdId() uint16

func (*TaggedReplicateRequest) CorrelationIdInActingVersion 

func (t *TaggedReplicateRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*TaggedReplicateRequest) CorrelationIdMaxValue 

func (*TaggedReplicateRequest) CorrelationIdMaxValue() int64

func (*TaggedReplicateRequest) CorrelationIdMetaAttribute 

func (*TaggedReplicateRequest) CorrelationIdMetaAttribute(meta int) string

func (*TaggedReplicateRequest) CorrelationIdMinValue 

func (*TaggedReplicateRequest) CorrelationIdMinValue() int64

func (*TaggedReplicateRequest) CorrelationIdNullValue 

func (*TaggedReplicateRequest) CorrelationIdNullValue() int64

func (*TaggedReplicateRequest) CorrelationIdSinceVersion 

func (*TaggedReplicateRequest) CorrelationIdSinceVersion() uint16

func (*TaggedReplicateRequest) Decode 

func (t *TaggedReplicateRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*TaggedReplicateRequest) DstRecordingIdDeprecated 

func (*TaggedReplicateRequest) DstRecordingIdDeprecated() uint16

func (*TaggedReplicateRequest) DstRecordingIdId 

func (*TaggedReplicateRequest) DstRecordingIdId() uint16

func (*TaggedReplicateRequest) DstRecordingIdInActingVersion 

func (t *TaggedReplicateRequest) DstRecordingIdInActingVersion(actingVersion uint16) bool

func (*TaggedReplicateRequest) DstRecordingIdMaxValue 

func (*TaggedReplicateRequest) DstRecordingIdMaxValue() int64

func (*TaggedReplicateRequest) DstRecordingIdMetaAttribute 

func (*TaggedReplicateRequest) DstRecordingIdMetaAttribute(meta int) string

func (*TaggedReplicateRequest) DstRecordingIdMinValue 

func (*TaggedReplicateRequest) DstRecordingIdMinValue() int64

func (*TaggedReplicateRequest) DstRecordingIdNullValue 

func (*TaggedReplicateRequest) DstRecordingIdNullValue() int64

func (*TaggedReplicateRequest) DstRecordingIdSinceVersion 

func (*TaggedReplicateRequest) DstRecordingIdSinceVersion() uint16

func (*TaggedReplicateRequest) Encode 

func (t *TaggedReplicateRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (TaggedReplicateRequest) LiveDestinationCharacterEncoding 

func (TaggedReplicateRequest) LiveDestinationCharacterEncoding() string

func (*TaggedReplicateRequest) LiveDestinationDeprecated 

func (*TaggedReplicateRequest) LiveDestinationDeprecated() uint16

func (TaggedReplicateRequest) LiveDestinationHeaderLength 

func (TaggedReplicateRequest) LiveDestinationHeaderLength() uint64

func (*TaggedReplicateRequest) LiveDestinationInActingVersion 

func (t *TaggedReplicateRequest) LiveDestinationInActingVersion(actingVersion uint16) bool

func (*TaggedReplicateRequest) LiveDestinationMetaAttribute 

func (*TaggedReplicateRequest) LiveDestinationMetaAttribute(meta int) string

func (*TaggedReplicateRequest) LiveDestinationSinceVersion 

func (*TaggedReplicateRequest) LiveDestinationSinceVersion() uint16

func (*TaggedReplicateRequest) RangeCheck 

func (t *TaggedReplicateRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*TaggedReplicateRequest) SbeBlockLength 

func (*TaggedReplicateRequest) SbeBlockLength() (blockLength uint16)

func (*TaggedReplicateRequest) SbeSchemaId 

func (*TaggedReplicateRequest) SbeSchemaId() (schemaId uint16)

func (*TaggedReplicateRequest) SbeSchemaVersion 

func (*TaggedReplicateRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*TaggedReplicateRequest) SbeSemanticType 

func (*TaggedReplicateRequest) SbeSemanticType() (semanticType []byte)

func (*TaggedReplicateRequest) SbeTemplateId 

func (*TaggedReplicateRequest) SbeTemplateId() (templateId uint16)

func (TaggedReplicateRequest) SrcControlChannelCharacterEncoding 

func (TaggedReplicateRequest) SrcControlChannelCharacterEncoding() string

func (*TaggedReplicateRequest) SrcControlChannelDeprecated 

func (*TaggedReplicateRequest) SrcControlChannelDeprecated() uint16

func (TaggedReplicateRequest) SrcControlChannelHeaderLength 

func (TaggedReplicateRequest) SrcControlChannelHeaderLength() uint64

func (*TaggedReplicateRequest) SrcControlChannelInActingVersion 

func (t *TaggedReplicateRequest) SrcControlChannelInActingVersion(actingVersion uint16) bool

func (*TaggedReplicateRequest) SrcControlChannelMetaAttribute 

func (*TaggedReplicateRequest) SrcControlChannelMetaAttribute(meta int) string

func (*TaggedReplicateRequest) SrcControlChannelSinceVersion 

func (*TaggedReplicateRequest) SrcControlChannelSinceVersion() uint16

func (*TaggedReplicateRequest) SrcControlStreamIdDeprecated 

func (*TaggedReplicateRequest) SrcControlStreamIdDeprecated() uint16

func (*TaggedReplicateRequest) SrcControlStreamIdId 

func (*TaggedReplicateRequest) SrcControlStreamIdId() uint16

func (*TaggedReplicateRequest) SrcControlStreamIdInActingVersion 

func (t *TaggedReplicateRequest) SrcControlStreamIdInActingVersion(actingVersion uint16) bool

func (*TaggedReplicateRequest) SrcControlStreamIdMaxValue 

func (*TaggedReplicateRequest) SrcControlStreamIdMaxValue() int32

func (*TaggedReplicateRequest) SrcControlStreamIdMetaAttribute 

func (*TaggedReplicateRequest) SrcControlStreamIdMetaAttribute(meta int) string

func (*TaggedReplicateRequest) SrcControlStreamIdMinValue 

func (*TaggedReplicateRequest) SrcControlStreamIdMinValue() int32

func (*TaggedReplicateRequest) SrcControlStreamIdNullValue 

func (*TaggedReplicateRequest) SrcControlStreamIdNullValue() int32

func (*TaggedReplicateRequest) SrcControlStreamIdSinceVersion 

func (*TaggedReplicateRequest) SrcControlStreamIdSinceVersion() uint16

func (*TaggedReplicateRequest) SrcRecordingIdDeprecated 

func (*TaggedReplicateRequest) SrcRecordingIdDeprecated() uint16

func (*TaggedReplicateRequest) SrcRecordingIdId 

func (*TaggedReplicateRequest) SrcRecordingIdId() uint16

func (*TaggedReplicateRequest) SrcRecordingIdInActingVersion 

func (t *TaggedReplicateRequest) SrcRecordingIdInActingVersion(actingVersion uint16) bool

func (*TaggedReplicateRequest) SrcRecordingIdMaxValue 

func (*TaggedReplicateRequest) SrcRecordingIdMaxValue() int64

func (*TaggedReplicateRequest) SrcRecordingIdMetaAttribute 

func (*TaggedReplicateRequest) SrcRecordingIdMetaAttribute(meta int) string

func (*TaggedReplicateRequest) SrcRecordingIdMinValue 

func (*TaggedReplicateRequest) SrcRecordingIdMinValue() int64

func (*TaggedReplicateRequest) SrcRecordingIdNullValue 

func (*TaggedReplicateRequest) SrcRecordingIdNullValue() int64

func (*TaggedReplicateRequest) SrcRecordingIdSinceVersion 

func (*TaggedReplicateRequest) SrcRecordingIdSinceVersion() uint16

func (*TaggedReplicateRequest) SubscriptionTagIdDeprecated 

func (*TaggedReplicateRequest) SubscriptionTagIdDeprecated() uint16

func (*TaggedReplicateRequest) SubscriptionTagIdId 

func (*TaggedReplicateRequest) SubscriptionTagIdId() uint16

func (*TaggedReplicateRequest) SubscriptionTagIdInActingVersion 

func (t *TaggedReplicateRequest) SubscriptionTagIdInActingVersion(actingVersion uint16) bool

func (*TaggedReplicateRequest) SubscriptionTagIdMaxValue 

func (*TaggedReplicateRequest) SubscriptionTagIdMaxValue() int64

func (*TaggedReplicateRequest) SubscriptionTagIdMetaAttribute 

func (*TaggedReplicateRequest) SubscriptionTagIdMetaAttribute(meta int) string

func (*TaggedReplicateRequest) SubscriptionTagIdMinValue 

func (*TaggedReplicateRequest) SubscriptionTagIdMinValue() int64

func (*TaggedReplicateRequest) SubscriptionTagIdNullValue 

func (*TaggedReplicateRequest) SubscriptionTagIdNullValue() int64

func (*TaggedReplicateRequest) SubscriptionTagIdSinceVersion 

func (*TaggedReplicateRequest) SubscriptionTagIdSinceVersion() uint16

type TruncateRecordingRequest 

type TruncateRecordingRequest struct {
	ControlSessionId int64
	CorrelationId    int64
	RecordingId      int64
	Position         int64
}

func (*TruncateRecordingRequest) ControlSessionIdDeprecated 

func (*TruncateRecordingRequest) ControlSessionIdDeprecated() uint16

func (*TruncateRecordingRequest) ControlSessionIdId 

func (*TruncateRecordingRequest) ControlSessionIdId() uint16

func (*TruncateRecordingRequest) ControlSessionIdInActingVersion 

func (t *TruncateRecordingRequest) ControlSessionIdInActingVersion(actingVersion uint16) bool

func (*TruncateRecordingRequest) ControlSessionIdMaxValue 

func (*TruncateRecordingRequest) ControlSessionIdMaxValue() int64

func (*TruncateRecordingRequest) ControlSessionIdMetaAttribute 

func (*TruncateRecordingRequest) ControlSessionIdMetaAttribute(meta int) string

func (*TruncateRecordingRequest) ControlSessionIdMinValue 

func (*TruncateRecordingRequest) ControlSessionIdMinValue() int64

func (*TruncateRecordingRequest) ControlSessionIdNullValue 

func (*TruncateRecordingRequest) ControlSessionIdNullValue() int64

func (*TruncateRecordingRequest) ControlSessionIdSinceVersion 

func (*TruncateRecordingRequest) ControlSessionIdSinceVersion() uint16

func (*TruncateRecordingRequest) CorrelationIdDeprecated 

func (*TruncateRecordingRequest) CorrelationIdDeprecated() uint16

func (*TruncateRecordingRequest) CorrelationIdId 

func (*TruncateRecordingRequest) CorrelationIdId() uint16

func (*TruncateRecordingRequest) CorrelationIdInActingVersion 

func (t *TruncateRecordingRequest) CorrelationIdInActingVersion(actingVersion uint16) bool

func (*TruncateRecordingRequest) CorrelationIdMaxValue 

func (*TruncateRecordingRequest) CorrelationIdMaxValue() int64

func (*TruncateRecordingRequest) CorrelationIdMetaAttribute 

func (*TruncateRecordingRequest) CorrelationIdMetaAttribute(meta int) string

func (*TruncateRecordingRequest) CorrelationIdMinValue 

func (*TruncateRecordingRequest) CorrelationIdMinValue() int64

func (*TruncateRecordingRequest) CorrelationIdNullValue 

func (*TruncateRecordingRequest) CorrelationIdNullValue() int64

func (*TruncateRecordingRequest) CorrelationIdSinceVersion 

func (*TruncateRecordingRequest) CorrelationIdSinceVersion() uint16

func (*TruncateRecordingRequest) Decode 

func (t *TruncateRecordingRequest) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16, blockLength uint16, doRangeCheck bool) error

func (*TruncateRecordingRequest) Encode 

func (t *TruncateRecordingRequest) Encode(_m *SbeGoMarshaller, _w io.Writer, doRangeCheck bool) error

func (*TruncateRecordingRequest) PositionDeprecated 

func (*TruncateRecordingRequest) PositionDeprecated() uint16

func (*TruncateRecordingRequest) PositionId 

func (*TruncateRecordingRequest) PositionId() uint16

func (*TruncateRecordingRequest) PositionInActingVersion 

func (t *TruncateRecordingRequest) PositionInActingVersion(actingVersion uint16) bool

func (*TruncateRecordingRequest) PositionMaxValue 

func (*TruncateRecordingRequest) PositionMaxValue() int64

func (*TruncateRecordingRequest) PositionMetaAttribute 

func (*TruncateRecordingRequest) PositionMetaAttribute(meta int) string

func (*TruncateRecordingRequest) PositionMinValue 

func (*TruncateRecordingRequest) PositionMinValue() int64

func (*TruncateRecordingRequest) PositionNullValue 

func (*TruncateRecordingRequest) PositionNullValue() int64

func (*TruncateRecordingRequest) PositionSinceVersion 

func (*TruncateRecordingRequest) PositionSinceVersion() uint16

func (*TruncateRecordingRequest) RangeCheck 

func (t *TruncateRecordingRequest) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*TruncateRecordingRequest) RecordingIdDeprecated 

func (*TruncateRecordingRequest) RecordingIdDeprecated() uint16

func (*TruncateRecordingRequest) RecordingIdId 

func (*TruncateRecordingRequest) RecordingIdId() uint16

func (*TruncateRecordingRequest) RecordingIdInActingVersion 

func (t *TruncateRecordingRequest) RecordingIdInActingVersion(actingVersion uint16) bool

func (*TruncateRecordingRequest) RecordingIdMaxValue 

func (*TruncateRecordingRequest) RecordingIdMaxValue() int64

func (*TruncateRecordingRequest) RecordingIdMetaAttribute 

func (*TruncateRecordingRequest) RecordingIdMetaAttribute(meta int) string

func (*TruncateRecordingRequest) RecordingIdMinValue 

func (*TruncateRecordingRequest) RecordingIdMinValue() int64

func (*TruncateRecordingRequest) RecordingIdNullValue 

func (*TruncateRecordingRequest) RecordingIdNullValue() int64

func (*TruncateRecordingRequest) RecordingIdSinceVersion 

func (*TruncateRecordingRequest) RecordingIdSinceVersion() uint16

func (*TruncateRecordingRequest) SbeBlockLength 

func (*TruncateRecordingRequest) SbeBlockLength() (blockLength uint16)

func (*TruncateRecordingRequest) SbeSchemaId 

func (*TruncateRecordingRequest) SbeSchemaId() (schemaId uint16)

func (*TruncateRecordingRequest) SbeSchemaVersion 

func (*TruncateRecordingRequest) SbeSchemaVersion() (schemaVersion uint16)

func (*TruncateRecordingRequest) SbeSemanticType 

func (*TruncateRecordingRequest) SbeSemanticType() (semanticType []byte)

func (*TruncateRecordingRequest) SbeTemplateId 

func (*TruncateRecordingRequest) SbeTemplateId() (templateId uint16)

type VarAsciiEncoding 

type VarAsciiEncoding struct {
	Length  uint32
	VarData uint8
}

func (*VarAsciiEncoding) Decode 

func (v *VarAsciiEncoding) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16) error

func (*VarAsciiEncoding) Encode 

func (v *VarAsciiEncoding) Encode(_m *SbeGoMarshaller, _w io.Writer) error

func (*VarAsciiEncoding) EncodedLength 

func (*VarAsciiEncoding) EncodedLength() int64

func (*VarAsciiEncoding) LengthDeprecated 

func (*VarAsciiEncoding) LengthDeprecated() uint16

func (*VarAsciiEncoding) LengthInActingVersion 

func (v *VarAsciiEncoding) LengthInActingVersion(actingVersion uint16) bool

func (*VarAsciiEncoding) LengthMaxValue 

func (*VarAsciiEncoding) LengthMaxValue() uint32

func (*VarAsciiEncoding) LengthMinValue 

func (*VarAsciiEncoding) LengthMinValue() uint32

func (*VarAsciiEncoding) LengthNullValue 

func (*VarAsciiEncoding) LengthNullValue() uint32

func (*VarAsciiEncoding) LengthSinceVersion 

func (*VarAsciiEncoding) LengthSinceVersion() uint16

func (*VarAsciiEncoding) RangeCheck 

func (v *VarAsciiEncoding) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*VarAsciiEncoding) VarDataDeprecated 

func (*VarAsciiEncoding) VarDataDeprecated() uint16

func (*VarAsciiEncoding) VarDataInActingVersion 

func (v *VarAsciiEncoding) VarDataInActingVersion(actingVersion uint16) bool

func (*VarAsciiEncoding) VarDataMaxValue 

func (*VarAsciiEncoding) VarDataMaxValue() uint8

func (*VarAsciiEncoding) VarDataMinValue 

func (*VarAsciiEncoding) VarDataMinValue() uint8

func (*VarAsciiEncoding) VarDataNullValue 

func (*VarAsciiEncoding) VarDataNullValue() uint8

func (*VarAsciiEncoding) VarDataSinceVersion 

func (*VarAsciiEncoding) VarDataSinceVersion() uint16

type VarDataEncoding 

type VarDataEncoding struct {
	Length  uint32
	VarData uint8
}

func (*VarDataEncoding) Decode 

func (v *VarDataEncoding) Decode(_m *SbeGoMarshaller, _r io.Reader, actingVersion uint16) error

func (*VarDataEncoding) Encode 

func (v *VarDataEncoding) Encode(_m *SbeGoMarshaller, _w io.Writer) error

func (*VarDataEncoding) EncodedLength 

func (*VarDataEncoding) EncodedLength() int64

func (*VarDataEncoding) LengthDeprecated 

func (*VarDataEncoding) LengthDeprecated() uint16

func (*VarDataEncoding) LengthInActingVersion 

func (v *VarDataEncoding) LengthInActingVersion(actingVersion uint16) bool

func (*VarDataEncoding) LengthMaxValue 

func (*VarDataEncoding) LengthMaxValue() uint32

func (*VarDataEncoding) LengthMinValue 

func (*VarDataEncoding) LengthMinValue() uint32

func (*VarDataEncoding) LengthNullValue 

func (*VarDataEncoding) LengthNullValue() uint32

func (*VarDataEncoding) LengthSinceVersion 

func (*VarDataEncoding) LengthSinceVersion() uint16

func (*VarDataEncoding) RangeCheck 

func (v *VarDataEncoding) RangeCheck(actingVersion uint16, schemaVersion uint16) error

func (*VarDataEncoding) VarDataDeprecated 

func (*VarDataEncoding) VarDataDeprecated() uint16

func (*VarDataEncoding) VarDataInActingVersion 

func (v *VarDataEncoding) VarDataInActingVersion(actingVersion uint16) bool

func (*VarDataEncoding) VarDataMaxValue 

func (*VarDataEncoding) VarDataMaxValue() uint8

func (*VarDataEncoding) VarDataMinValue 

func (*VarDataEncoding) VarDataMinValue() uint8

func (*VarDataEncoding) VarDataNullValue 

func (*VarDataEncoding) VarDataNullValue() uint8

func (*VarDataEncoding) VarDataSinceVersion 

func (*VarDataEncoding) VarDataSinceVersion() uint16

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.