quickfix

package module

Go to main page

Versions in this module

v1

v1.1.2

Apr 18, 2024

v1.1.1

Apr 16, 2024

v1.1.0

Apr 16, 2024

v1.0.9

Jun 20, 2023

v1.0.8

Jun 20, 2023

v1.0.7

Aug 24, 2022

v1.0.6

Aug 24, 2022

Changes in this version

type SessionID

+ DropCopy bool

v1.0.5

Jun 21, 2022

Changes in this version

type SessionID

+ OnBehalfOfCompID string

v1.0.4

May 23, 2022

v1.0.3

May 23, 2022

v1.0.2

May 23, 2022

v1.0.1

May 23, 2022

Changes in this version

+ const ApplVerIDFIX27

+ const ApplVerIDFIX30

+ const ApplVerIDFIX40

+ const ApplVerIDFIX41

+ const ApplVerIDFIX42

+ const ApplVerIDFIX43

+ const ApplVerIDFIX44

+ const ApplVerIDFIX50

+ const ApplVerIDFIX50SP1

+ const ApplVerIDFIX50SP2

+ const BeginStringFIX40

+ const BeginStringFIX41

+ const BeginStringFIX42

+ const BeginStringFIX43

+ const BeginStringFIX44

+ const BeginStringFIXT11

+ func UnregisterSession(sessionID SessionID) error

type Acceptor

+ func (a *Acceptor) RemoteAddr(sessionID SessionID) (net.Addr, bool)

+ func (a *Acceptor) SetConnectionValidator(validator ConnectionValidator)

+ type ConnectionValidator interface

+ Validate func(netConn net.Conn, session SessionID) error

type FIXUTCTimestamp

+ Precision TimestampPrecision

type FieldMap

+ func (m *FieldMap) CopyInto(to *FieldMap)

type Message

+ func (m *Message) CopyInto(to *Message)

type MessageRejectError

+ func NewBusinessMessageRejectErrorWithRefID(err string, rejectReason int, businessRejectRefID string, refTagID *Tag) MessageRejectError

+ BusinessRejectRefID func() string

type MessageStoreFactory

+ func NewMongoStoreFactory(settings *Settings) MessageStoreFactory

+ func NewMongoStoreFactoryPrefixed(settings *Settings, collectionsPrefix string) MessageStoreFactory

type RejectLogon

+ func (RejectLogon) BusinessRejectRefID() string

+ type TimestampPrecision int

+ const Micros

+ const Millis

+ const Nanos

+ const Seconds

+ type Validator interface

+ Validate func(*Message) MessageRejectError

+ func NewValidator(settings ValidatorSettings, ...) Validator

+ type ValidatorSettings struct

+ CheckFieldsOutOfOrder bool

+ RejectInvalidMessage bool

v0

v0.6.0

Aug 14, 2017

Changes in this version

+ func ParseMessageWithDataDictionary(msg *Message, rawMessage *bytes.Buffer, ...) (err error)

type Body

+ func (t Body) Len() int

+ func (t Body) Less(i, j int) bool

+ func (t Body) Swap(i, j int)

+ type FIXBytes []byte

+ func (f *FIXBytes) Read(bytes []byte) (err error)

+ func (f FIXBytes) Write() []byte

type FieldMap

+ func (m *FieldMap) SetBool(tag Tag, value bool) *FieldMap

+ func (m *FieldMap) SetBytes(tag Tag, value []byte) *FieldMap

+ func (m FieldMap) GetBool(tag Tag) (bool, MessageRejectError)

+ func (m FieldMap) GetBytes(tag Tag) ([]byte, MessageRejectError)

+ func (m FieldMap) GetTime(tag Tag) (t time.Time, err MessageRejectError)

+ func (t FieldMap) Len() int

+ func (t FieldMap) Less(i, j int) bool

+ func (t FieldMap) Swap(i, j int)

type Group

+ func (t Group) Len() int

+ func (t Group) Less(i, j int) bool

+ func (t Group) Swap(i, j int)

type Header

+ func (t Header) Len() int

+ func (t Header) Less(i, j int) bool

+ func (t Header) Swap(i, j int)

type Message

+ func (m *Message) IsMsgTypeOf(msgType enum.MsgType) bool

+ func (m *Message) MsgType() (enum.MsgType, MessageRejectError)

type Trailer

+ func (t Trailer) Len() int

+ func (t Trailer) Less(i, j int) bool

+ func (t Trailer) Swap(i, j int)

v0.5.0

Sep 1, 2016

Changes in this version

+ var ErrDoNotSend = errors.New("Do Not Send")

+ type ConditionallyRequiredSetting struct

+ Setting string

+ func (e ConditionallyRequiredSetting) Error() string

+ type FIXDecimal struct

+ Scale int32

+ func (d *FIXDecimal) Read(bytes []byte) (err error)

+ func (d FIXDecimal) Write() []byte

type FieldMap

+ func (m FieldMap) SetInt(tag Tag, value int) FieldMap

+ func (m FieldMap) SetString(tag Tag, value string) FieldMap

+ type IncorrectFormatForSetting struct

+ Err error

+ Setting string

+ Value string

+ func (e IncorrectFormatForSetting) Error() string

+ type RejectLogon struct

+ Text string

+ func (RejectLogon) IsBusinessReject() bool

+ func (RejectLogon) RefTagID() *Tag

+ func (RejectLogon) RejectReason() int

+ func (e RejectLogon) Error() string

v0.4.0

Aug 1, 2016

Changes in this version

type FIXBoolean

+ func (f FIXBoolean) Bool() bool

type FIXFloat

+ func (f FIXFloat) Float64() float64

type FIXInt

+ func (f FIXInt) Int() int

type GroupItem

+ Clone func() GroupItem

type GroupTemplate

+ func (gt GroupTemplate) Clone() GroupTemplate

+ type Messagable interface

+ ToMessage func() Message

type Message

+ func (m Message) ToMessage() Message

type RepeatingGroup

+ func (f RepeatingGroup) Clone() GroupItem

v0.3.0

Jun 3, 2016

Changes in this version

+ type Body struct

+ func (b *Body) Init()

+ type FieldGroup interface

+ Read func(TagValues) (TagValues, error)

+ Tag func() Tag

+ Write func() TagValues

+ type FieldGroupReader interface

+ Read func(TagValues) (TagValues, error)

+ Tag func() Tag

+ type FieldGroupWriter interface

+ Tag func() Tag

+ Write func() TagValues

type GroupItem

+ Read func(TagValues) (TagValues, error)

+ type Header struct

+ func (h *Header) Init()

type Message

+ func ParseMessage(rawMessage []byte) (Message, error)

type MessageRejectError

+ func IncorrectDataFormatForValue(tag Tag) MessageRejectError

+ func InvalidMessageType() MessageRejectError

+ func InvalidTagNumber(tag Tag) MessageRejectError

+ func RequiredTagMissing(tag Tag) MessageRejectError

+ func TagNotDefinedForThisMessageType(tag Tag) MessageRejectError

+ func TagSpecifiedWithoutAValue(tag Tag) MessageRejectError

+ func UnsupportedMessageType() MessageRejectError

type RepeatingGroup

+ func NewRepeatingGroup(tag Tag, template GroupTemplate) *RepeatingGroup

+ func (f *RepeatingGroup) Read(tv TagValues) (TagValues, error)

+ func (f RepeatingGroup) Get(i int) Group

+ func (f RepeatingGroup) Len() int

+ func (f RepeatingGroup) Tag() Tag

+ func (f RepeatingGroup) Write() TagValues

type SessionID

+ func (s SessionID) IsFIXT() bool

type SessionSettings

+ func (s *SessionSettings) DurationSetting(setting string) (val time.Duration, err error)

+ type TagValue struct

+ func (tv TagValue) String() string

+ type TagValues []TagValue

+ type Trailer struct

+ func (t *Trailer) Init()

v0.2.0

Apr 19, 2016

Changes in this version

type FieldMap

+ func (m FieldMap) GetInt(tag Tag) (int, MessageRejectError)

+ func (m FieldMap) GetString(tag Tag) (string, MessageRejectError)

type MessageStore

+ Close func() error

type MessageStoreFactory

+ func NewFileStoreFactory(settings *Settings) MessageStoreFactory

+ func NewSQLStoreFactory(settings *Settings) MessageStoreFactory

type SessionID

+ SenderLocationID string

+ SenderSubID string

+ TargetLocationID string

+ TargetSubID string

v0.1.0

Feb 21, 2016

Changes in this version

+ func Send(m Marshaler) (err error)

+ func SendToTarget(m Marshaler, sessionID SessionID) error

+ type Acceptor struct

+ func NewAcceptor(app Application, storeFactory MessageStoreFactory, settings *Settings, ...) (*Acceptor, error)

+ func (a *Acceptor) Start() (e error)

+ func (a *Acceptor) Stop()

+ type Application interface

+ FromAdmin func(message Message, sessionID SessionID) MessageRejectError

+ FromApp func(message Message, sessionID SessionID) MessageRejectError

+ OnCreate func(sessionID SessionID)

+ OnLogon func(sessionID SessionID)

+ OnLogout func(sessionID SessionID)

+ ToAdmin func(message Message, sessionID SessionID)

+ ToApp func(message Message, sessionID SessionID) error

+ type FIXBoolean bool

+ func NewFIXBoolean(val bool) *FIXBoolean

+ func (f *FIXBoolean) Read(bytes []byte) error

+ func (f FIXBoolean) Write() []byte

+ type FIXFloat float64

+ func NewFIXFloat(val float64) *FIXFloat

+ func (f *FIXFloat) Read(bytes []byte) error

+ func (f FIXFloat) Write() []byte

+ type FIXInt int

+ func NewFIXInt(val int) *FIXInt

+ func (f *FIXInt) Read(bytes []byte) error

+ func (f FIXInt) Write() []byte

+ type FIXString string

+ func NewFIXString(val string) *FIXString

+ func (f *FIXString) Read(bytes []byte) (err error)

+ func (f FIXString) String() string

+ func (f FIXString) Write() []byte

+ type FIXUTCTimestamp struct

+ NoMillis bool

+ Value time.Time

+ func (f *FIXUTCTimestamp) Read(bytes []byte) error

+ func (f FIXUTCTimestamp) Write() []byte

+ type Field interface

+ type FieldMap struct

+ func (m *FieldMap) Clear()

+ func (m FieldMap) Get(parser Field) MessageRejectError

+ func (m FieldMap) GetField(tag Tag, parser FieldValueReader) MessageRejectError

+ func (m FieldMap) GetGroup(parser *RepeatingGroup) MessageRejectError

+ func (m FieldMap) Has(tag Tag) bool

+ func (m FieldMap) Set(field FieldWriter) FieldMap

+ func (m FieldMap) SetField(tag Tag, field FieldValueWriter) FieldMap

+ func (m FieldMap) SetGroup(field RepeatingGroup) FieldMap

+ func (m FieldMap) Tags() []Tag

+ type FieldValue interface

+ type FieldValueReader interface

+ Read func([]byte) error

+ type FieldValueWriter interface

+ Write func() []byte

+ type FieldWriter interface

+ Tag func() Tag

+ type Group struct

+ type GroupItem interface

+ Tag func() Tag

+ func GroupElement(tag Tag) GroupItem

+ type GroupTemplate []GroupItem

+ type Initiator struct

+ func NewInitiator(app Application, storeFactory MessageStoreFactory, appSettings *Settings, ...) (*Initiator, error)

+ func (i *Initiator) Start() error

+ func (i *Initiator) Stop()

+ type Log interface

+ OnEvent func(string)

+ OnEventf func(string, ...interface{})

+ OnIncoming func(string)

+ OnOutgoing func(string)

+ type LogFactory interface

+ Create func() (Log, error)

+ CreateSessionLog func(sessionID SessionID) (Log, error)

+ func NewFileLogFactory(settings *Settings) (LogFactory, error)

+ func NewNullLogFactory() LogFactory

+ func NewScreenLogFactory() LogFactory

+ type Marshaler interface

+ Marshal func() Message

+ type Message struct

+ Body FieldMap

+ Header FieldMap

+ ReceiveTime time.Time

+ Trailer FieldMap

+ func Marshal(v interface{}) Message

+ func NewMessage() (m Message)

+ func (m *Message) Build() ([]byte, error)

+ func (m *Message) Init()

+ func (m *Message) String() string

+ func (m Message) Marshal() Message

+ type MessageRejectError interface

+ IsBusinessReject func() bool

+ RefTagID func() *Tag

+ RejectReason func() int

+ func ConditionallyRequiredFieldMissing(tag Tag) MessageRejectError

+ func NewBusinessMessageRejectError(err string, rejectReason int, refTagID *Tag) MessageRejectError

+ func NewMessageRejectError(err string, rejectReason int, refTagID *Tag) MessageRejectError

+ func Unmarshal(m Message, v interface{}) MessageRejectError

+ func ValueIsIncorrect(tag Tag) MessageRejectError

+ type MessageRoute func(msg Message, sessionID SessionID) MessageRejectError

+ type MessageRouter struct

+ func NewMessageRouter() *MessageRouter

+ func (c MessageRouter) AddRoute(beginString string, msgType string, router MessageRoute)

+ func (c MessageRouter) Route(msg Message, sessionID SessionID) MessageRejectError

+ type MessageStore interface

+ CreationTime func() time.Time

+ GetMessages func(beginSeqNum, endSeqNum int) chan []byte

+ IncrNextSenderMsgSeqNum func()

+ IncrNextTargetMsgSeqNum func()

+ NextSenderMsgSeqNum func() int

+ NextTargetMsgSeqNum func() int

+ Refresh func()

+ Reset func()

+ SaveMessage func(seqNum int, msg []byte)

+ SetNextSenderMsgSeqNum func(next int)

+ SetNextTargetMsgSeqNum func(next int)

+ type MessageStoreFactory interface

+ Create func(sessionID SessionID) (MessageStore, error)

+ func NewMemoryStoreFactory() MessageStoreFactory

+ type RepeatingGroup struct

+ Groups []Group

+ func (f *RepeatingGroup) Add() Group

+ type SessionID struct

+ BeginString string

+ Qualifier string

+ SenderCompID string

+ TargetCompID string

+ func (s SessionID) String() string

+ type SessionSettings struct

+ func NewSessionSettings() *SessionSettings

+ func (s *SessionSettings) HasSetting(setting string) bool

+ func (s *SessionSettings) Init()

+ func (s *SessionSettings) IntSetting(setting string) (int, error)

+ func (s *SessionSettings) Set(setting string, val string)

+ func (s *SessionSettings) Setting(setting string) (string, error)

+ func (s SessionSettings) BoolSetting(setting string) (bool, error)

+ type Settings struct

+ func NewSettings() *Settings

+ func ParseSettings(reader io.Reader) (*Settings, error)

+ func (s *Settings) AddSession(sessionSettings *SessionSettings) (SessionID, error)

+ func (s *Settings) GlobalSettings() *SessionSettings

+ func (s *Settings) Init()

+ func (s *Settings) SessionSettings() map[SessionID]*SessionSettings

+ type Tag int

+ func (t Tag) IsHeader() bool

+ func (t Tag) IsTrailer() bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL