SbeRecordSerializer
SBE grab serializer — códigos/decódigos Fijar* estructuras de registro a/desde el formato binario SBE. Usa Ecng SpanWriter / SpanReader para la serialización binaria directa.
Métodos
public FixBoardLookup? ReadBoardLookup(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadBoardLookup(buffer)
Lea FixBoardLookup desde formato binario SBE.
public FixBoardUpdate? ReadBoardUpdate(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadBoardUpdate(buffer)
Lea FixBoardUpdate desde formato binario SBE.
public FixDataTypeLookup? ReadDataTypeLookup(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadDataTypeLookup(buffer)
Lea FixDataTypeLookup desde formato binario SBE.
public FixExecutionReport? ReadExecutionReport(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadExecutionReport(buffer)
Lea FixExecutionReport desde formato binario SBE.
private static FixId ReadFixId(SpanReader reader)
result = SbeRecordSerializer.ReadFixId(reader)
Read a FixId: [int64 N (NullableInt64)][uint16 strLen][UTF-8 bytes].
public static ValueTuple<ushort, ushort, ushort, ushort> ReadHeader(SpanReader reader)
result = SbeRecordSerializer.ReadHeader(reader)
Lea el encabezado del mensaje SBE.
public FixHeartbeat? ReadHeartbeat(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadHeartbeat(buffer)
Lea FixHeartbeat desde formato binario SBE.
public FixHistoryStart? ReadHistoryStart(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadHistoryStart(buffer)
Lea FixHistoryStart desde formato binario SBE.
public ValueTuple<SecurityId, string, DataType, DateTime, List<KeyValuePair<Level1Fields, object>>>? ReadLevel1Change(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadLevel1Change(buffer)
Lea un mensaje SBE de Nivel1Cambia.
public FixLogonResponse? ReadLogonResponse(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadLogonResponse(buffer)
Lea FixLogonResponse desde formato binario SBE.
public FixMarketDataIncrementalRefresh? ReadMarketDataIncrementalRefresh(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadMarketDataIncrementalRefresh(buffer)
Lea un mensaje MarketDataIncrementalRefreshSBE.
public FixMarketDataRequest? ReadMarketDataRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadMarketDataRequest(buffer)
Lea un mensaje MarketDataRequestSBE.
public FixMarketDataRequestReject? ReadMarketDataRequestReject(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadMarketDataRequestReject(buffer)
Lea FixMarketDataRequestReject desde formato binario SBE.
public FixMarketDataSnapshotFullRefresh? ReadMarketDataSnapshotFullRefresh(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadMarketDataSnapshotFullRefresh(buffer)
Lea un mensaje MarketDataSnapshotFullRefreshSBE.
public FixNewOrderSingle? ReadNewOrderSingle(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadNewOrderSingle(buffer)
Lea FixNewOrderSingle desde formato binario SBE.
public FixOrderCancelReject? ReadOrderCancelReject(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadOrderCancelReject(buffer)
Lea FixOrderCancelReject desde formato binario SBE.
public FixOrderCancelReplaceRequest? ReadOrderCancelReplaceRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadOrderCancelReplaceRequest(buffer)
Lea FixOrderCancelReplaceRequest desde formato binario SBE.
public FixOrderCancelRequest? ReadOrderCancelRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadOrderCancelRequest(buffer)
Lea FixOrderCancelRequest desde formato binario SBE.
public FixOrderMassCancelReport? ReadOrderMassCancelReport(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadOrderMassCancelReport(buffer)
Lea FixOrderMassCancelReport desde formato binario SBE.
public FixOrderMassCancelRequest? ReadOrderMassCancelRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadOrderMassCancelRequest(buffer)
Lea FixOrderMassCancelRequest desde formato binario SBE.
public FixOrderMassStatusRequest? ReadOrderMassStatusRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadOrderMassStatusRequest(buffer)
Lea FixOrderMassStatusRequest desde formato binario SBE.
public FixOrderStatusRequest? ReadOrderStatusRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadOrderStatusRequest(buffer)
Lea FixOrderStatusRequest desde formato binario SBE.
private static FixParty[] ReadParties(SpanReader reader)
result = SbeRecordSerializer.ReadParties(reader)
Lea un grupo repetidor de FixParty.
public FixPositionReport? ReadPositionReport(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadPositionReport(buffer)
Lea FixPositionReport desde formato binario SBE.
public FixReject? ReadReject(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadReject(buffer)
Lea FixReject desde formato binario SBE.
public FixRemove? ReadRemove(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadRemove(buffer)
Lea FixRemove desde formato binario SBE.
public FixRequestForPositions? ReadRequestForPositions(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadRequestForPositions(buffer)
Lea FixRequestForPositions desde formato binario SBE.
public FixResendRequest? ReadResendRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadResendRequest(buffer)
Lea FixResendRequest desde formato binario SBE.
public FixSecurityLegsRequest? ReadSecurityLegsRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadSecurityLegsRequest(buffer)
Lea FixSecurityLegsRequest desde formato binario SBE.
public FixSecurityListRequest? ReadSecurityListRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadSecurityListRequest(buffer)
Lea FixSecurityListRequest desde formato binario SBE.
public ValueTuple<FixId, FixId, SecurityMessage[]>? ReadSecurityListResponse(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadSecurityListResponse(buffer)
Lea SecurityListResponse desde formato binario SBE.
public FixSecurityListResponseError? ReadSecurityListResponseError(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadSecurityListResponseError(buffer)
Lea FixSecurityListResponseError desde formato binario SBE.
public FixSecurityMapping? ReadSecurityMapping(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadSecurityMapping(buffer)
Lea FixSecurityMapping desde formato binario SBE.
public FixSecurityStatusRequest? ReadSecurityStatusRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadSecurityStatusRequest(buffer)
Lea FixSecurityStatusRequest desde formato binario SBE.
public FixSequenceReset? ReadSequenceReset(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadSequenceReset(buffer)
Lea FixSequenceReset desde formato binario SBE.
private static string[] ReadStringArray(SpanReader reader)
result = SbeRecordSerializer.ReadStringArray(reader)
Lee un array de cuerdas.
public FixId? ReadSubscriptionFinished(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadSubscriptionFinished(buffer)
Lea un mensaje SubscriptionFinished de formato binario SBE.
public FixSubscriptionOnline? ReadSubscriptionOnline(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadSubscriptionOnline(buffer)
Lea FixSubscriptionOnline desde formato binario SBE.
public FixSubscriptionResponse? ReadSubscriptionResponse(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadSubscriptionResponse(buffer)
Lea FixSubscriptionResponse desde formato binario SBE.
public FixTestRequest? ReadTestRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadTestRequest(buffer)
Lea FixTestRequest desde formato binario SBE.
public FixTradingSessionStatusRequest? ReadTradingSessionStatusRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadTradingSessionStatusRequest(buffer)
Lea FixTradingSessionStatusRequest desde formato binario SBE.
public FixUserRequest? ReadUserRequest(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadUserRequest(buffer)
Lea FixUserRequest desde formato binario SBE.
public FixUserRequestEx? ReadUserRequestEx(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadUserRequestEx(buffer)
Lea FixUserRequestEx desde formato binario SBE.
public FixUserResponse? ReadUserResponse(ReadOnlySpan<byte> buffer)
result = sbeRecordSerializer.ReadUserResponse(buffer)
Lea FixUserResponse desde formato binario SBE.
internal static string ReadVarStringFromReader(SpanReader reader)
result = SbeRecordSerializer.ReadVarStringFromReader(reader)
Leer una cadena de longitud variable: [uint16 longitud][UTF-8 bytes]. Largo 0 devuelve nulo.
public int WriteBoardLookup(FixBoardLookup data, Span<byte> buffer)
result = sbeRecordSerializer.WriteBoardLookup(data, buffer)
Escribe FixBoardLookup a SBE formato binario.
public int WriteBoardUpdate(FixBoardUpdate data, Span<byte> buffer)
result = sbeRecordSerializer.WriteBoardUpdate(data, buffer)
Escribe FixBoardUpdate a SBE formato binario.
public int WriteDataTypeLookup(FixDataTypeLookup data, Span<byte> buffer)
result = sbeRecordSerializer.WriteDataTypeLookup(data, buffer)
Escribe FixDataTypeLookup a SBE formato binario.
public int WriteExecutionReport(FixExecutionReport data, Span<byte> buffer)
result = sbeRecordSerializer.WriteExecutionReport(data, buffer)
Escribe FixExecutionReport a SBE formato binario.
private static void WriteFixId(SpanWriter writer, FixId id)
SbeRecordSerializer.WriteFixId(writer, id)
Write a FixId: [int64 N (NullableInt64)][uint16 strLen][UTF-8 bytes].
public static void WriteHeader(SpanWriter writer, ushort blockLength, ushort templateId)
SbeRecordSerializer.WriteHeader(writer, blockLength, templateId)
Escribe el encabezado del mensaje SBE.
public int WriteHeartbeat(FixHeartbeat data, Span<byte> buffer)
result = sbeRecordSerializer.WriteHeartbeat(data, buffer)
Escribe FixHeartbeat a SBE formato binario.
public int WriteHistoryStart(FixHistoryStart data, Span<byte> buffer)
result = sbeRecordSerializer.WriteHistoryStart(data, buffer)
Escribe FixHistoryStart a SBE formato binario.
public int WriteLevel1Change(SecurityId securityId, string mdReqId, DataType buildFrom, DateTime serverTime, IDictionary<Level1Fields, object> changes, Span<byte> buffer)
result = sbeRecordSerializer.WriteLevel1Change(securityId, mdReqId, buildFrom, serverTime, changes, buffer)
VarStringKEN1 cuenta SBE mensaje con pares de valor claves tipo.Ejecución: [Asesino][VarString][VarString boardCode] [VarString mdReqId] [VarStringKEN12]
public int WriteLogonResponse(FixLogonResponse data, Span<byte> buffer)
result = sbeRecordSerializer.WriteLogonResponse(data, buffer)
Escribe FixLogonResponse a SBE formato binario.
public int WriteMarketDataIncrementalRefresh(FixMarketDataIncrementalRefresh data, Span<byte> buffer)
result = sbeRecordSerializer.WriteMarketDataIncrementalRefresh(data, buffer)
Escribe un mensaje MarketDataIncrementalRefresh SBE. Diseño: [Header][VarString symbol][VarString securityExchange][VarString mdReqId] [NullableChar buildFromType] [VarString buildFromArg] [Ingresos] [Ingresos] [Ingresos] [Ingresos] [Ingresos] [Ingresos] [Ingresos] [Ingresos] [en]
public int WriteMarketDataRequest(FixMarketDataRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteMarketDataRequest(data, buffer)
[Conteo]Contable de la cadena [Construido de la cadena] [Construido de la cadena] [Construido de la cadena] [Construido de la cadena]
public int WriteMarketDataRequestReject(FixMarketDataRequestReject data, Span<byte> buffer)
result = sbeRecordSerializer.WriteMarketDataRequestReject(data, buffer)
Escribe FixMarketDataRequestReject a SBE formato binario.
public int WriteMarketDataSnapshotFullRefresh(FixMarketDataSnapshotFullRefresh data, Span<byte> buffer)
result = sbeRecordSerializer.WriteMarketDataSnapshotFullRefresh(data, buffer)
Escribe un mensaje MarketDataSnapshotFullRefresh SBE. Diseño: [Header][VarString symbol][VarString boardCode][VarString mdReqId] [NullableChar buildFromType] [VarString buildFromArg] [Ingresos] [Ingresos] [Ingresos] [Ingresos] [Ingresos] [Ingresos] [Ingresos] [Ingresos] [en]
public int WriteNewOrderSingle(FixNewOrderSingle data, Span<byte> buffer)
result = sbeRecordSerializer.WriteNewOrderSingle(data, buffer)
Escribe FixNewOrderSingle a SBE formato binario.
public int WriteOrderCancelReject(FixOrderCancelReject data, Span<byte> buffer)
result = sbeRecordSerializer.WriteOrderCancelReject(data, buffer)
Escribe FixOrderCancelReject a SBE formato binario.
public int WriteOrderCancelReplaceRequest(FixOrderCancelReplaceRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteOrderCancelReplaceRequest(data, buffer)
Escribe FixOrderCancelReplaceRequest a SBE formato binario.
public int WriteOrderCancelRequest(FixOrderCancelRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteOrderCancelRequest(data, buffer)
Escribe FixOrderCancelRequest a SBE formato binario.
public int WriteOrderMassCancelReport(FixOrderMassCancelReport data, Span<byte> buffer)
result = sbeRecordSerializer.WriteOrderMassCancelReport(data, buffer)
Escribe FixOrderMassCancelReport a SBE formato binario.
public int WriteOrderMassCancelRequest(FixOrderMassCancelRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteOrderMassCancelRequest(data, buffer)
Escribe FixOrderMassCancelRequest a SBE formato binario.
public int WriteOrderMassStatusRequest(FixOrderMassStatusRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteOrderMassStatusRequest(data, buffer)
Escribe FixOrderMassStatusRequest a SBE formato binario.
public int WriteOrderStatusRequest(FixOrderStatusRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteOrderStatusRequest(data, buffer)
Escribe FixOrderStatusRequest a SBE formato binario.
private static void WriteParties(SpanWriter writer, FixParty[] parties)
SbeRecordSerializer.WriteParties(writer, parties)
Write a repeating group of FixParty: [uint16 count][parties...]. Each party: [VarString partyId][int32 partyRole].
public int WritePositionReport(FixPositionReport data, Span<byte> buffer)
result = sbeRecordSerializer.WritePositionReport(data, buffer)
Escribe FixPositionReport a SBE formato binario.
public int WriteReject(FixReject data, Span<byte> buffer)
result = sbeRecordSerializer.WriteReject(data, buffer)
Escribe FixReject a SBE formato binario.
public int WriteRemove(FixRemove data, Span<byte> buffer)
result = sbeRecordSerializer.WriteRemove(data, buffer)
Escribe FixRemove a SBE formato binario.
public int WriteRequestForPositions(FixRequestForPositions data, Span<byte> buffer)
result = sbeRecordSerializer.WriteRequestForPositions(data, buffer)
Escribe FixRequestForPositions a SBE formato binario.
public int WriteResendRequest(FixResendRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteResendRequest(data, buffer)
Escribe FixResendRequest a SBE formato binario.
public int WriteSecurityLegsRequest(FixSecurityLegsRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteSecurityLegsRequest(data, buffer)
Escribe FixSecurityLegsRequest a SBE formato binario.
public int WriteSecurityListRequest(FixSecurityListRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteSecurityListRequest(data, buffer)
Escribe FixSecurityListRequest a SBE formato binario.
public int WriteSecurityListResponse(FixId securityReqId, FixId securityResponseId, ICollection<SecurityMessage> securities, Span<byte> buffer)
result = sbeRecordSerializer.WriteSecurityListResponse(securityReqId, securityResponseId, securities, buffer)
Escribe SecurityListResponse a SBE formato binario.
public int WriteSecurityListResponseError(FixSecurityListResponseError data, Span<byte> buffer)
result = sbeRecordSerializer.WriteSecurityListResponseError(data, buffer)
Escribe FixSecurityListResponseError a SBE formato binario.
public int WriteSecurityMapping(FixSecurityMapping data, Span<byte> buffer)
result = sbeRecordSerializer.WriteSecurityMapping(data, buffer)
Escribe FixSecurityMapping a SBE formato binario.
public int WriteSecurityStatusRequest(FixSecurityStatusRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteSecurityStatusRequest(data, buffer)
Escribe FixSecurityStatusRequest a SBE formato binario.
public int WriteSequenceReset(FixSequenceReset data, Span<byte> buffer)
result = sbeRecordSerializer.WriteSequenceReset(data, buffer)
Escribe FixSequenceReset a SBE formato binario.
private static void WriteStringArray(SpanWriter writer, string[] values)
SbeRecordSerializer.WriteStringArray(writer, values)
Escribe un array de cadena: [uint16 count][VarStrings...].
public int WriteSubscriptionFinished(FixId mdReqId, Span<byte> buffer)
result = sbeRecordSerializer.WriteSubscriptionFinished(mdReqId, buffer)
Escribe un mensaje SubscriptionFinished a formato binario SBE.
public int WriteSubscriptionOnline(FixSubscriptionOnline data, Span<byte> buffer)
result = sbeRecordSerializer.WriteSubscriptionOnline(data, buffer)
Escribe FixSubscriptionOnline a SBE formato binario.
public int WriteSubscriptionResponse(FixSubscriptionResponse data, Span<byte> buffer)
result = sbeRecordSerializer.WriteSubscriptionResponse(data, buffer)
Escribe FixSubscriptionResponse a SBE formato binario.
public int WriteTestRequest(FixTestRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteTestRequest(data, buffer)
Escribe FixTestRequest a SBE formato binario.
public int WriteTradingSessionStatusRequest(FixTradingSessionStatusRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteTradingSessionStatusRequest(data, buffer)
Escribe FixTradingSessionStatusRequest a SBE formato binario.
public int WriteUserRequest(FixUserRequest data, Span<byte> buffer)
result = sbeRecordSerializer.WriteUserRequest(data, buffer)
Escribe FixUserRequest a SBE formato binario.
public int WriteUserRequestEx(FixUserRequestEx data, Span<byte> buffer)
result = sbeRecordSerializer.WriteUserRequestEx(data, buffer)
Escribe FixUserRequestEx a SBE formato binario.
public int WriteUserResponse(FixUserResponse data, Span<byte> buffer)
result = sbeRecordSerializer.WriteUserResponse(data, buffer)
Escribe FixUserResponse a SBE formato binario.
private static void WriteVarString(SpanWriter writer, string value)
SbeRecordSerializer.WriteVarString(writer, value)
Escribe una cadena de longitud variable: [longitud Uint16][Orretos UT-8]. La cadena nula está escrita como longitud = 0.
Campos
public const int HeaderSize
value = SbeRecordSerializer.HeaderSize
SBE MessageHeadertamaño en bytes.
public const ushort SchemaId
value = SbeRecordSerializer.SchemaId
Identificador de esquema SBE.
public const ushort SchemaVersion
value = SbeRecordSerializer.SchemaVersion
Versión de esquema SBE.