quickfix

package module

Go to main page

Versions in this module

v0

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