Versions in this module Expand all Collapse all v0 v0.5.0 Sep 1, 2016 Changes in this version + var ErrDoNotSend = errors.New("Do Not Send") + func Send(m Messagable) (err error) + func SendToTarget(m Messagable, sessionID SessionID) error + type Acceptor struct + func NewAcceptor(app Application, storeFactory MessageStoreFactory, settings *Settings, ...) (a *Acceptor, err error) + func (a *Acceptor) Start() 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 Body struct + func (b *Body) Init() + type ConditionallyRequiredSetting struct + Setting string + func (e ConditionallyRequiredSetting) Error() string + type FIXBoolean bool + func (f *FIXBoolean) Read(bytes []byte) error + func (f FIXBoolean) Bool() bool + func (f FIXBoolean) Write() []byte + type FIXDecimal struct + Scale int32 + func (d *FIXDecimal) Read(bytes []byte) (err error) + func (d FIXDecimal) Write() []byte + type FIXFloat float64 + func (f *FIXFloat) Read(bytes []byte) error + func (f FIXFloat) Float64() float64 + func (f FIXFloat) Write() []byte + type FIXInt int + func (f *FIXInt) Read(bytes []byte) error + func (f FIXInt) Int() int + func (f FIXInt) Write() []byte + type FIXString string + func (f *FIXString) Read(bytes []byte) (err error) + func (f FIXString) String() string + func (f FIXString) Write() []byte + type FIXUTCTimestamp struct + NoMillis bool + func (f *FIXUTCTimestamp) Read(bytes []byte) error + func (f FIXUTCTimestamp) Write() []byte + type Field interface + 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 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 FieldGroupReader) MessageRejectError + func (m FieldMap) GetInt(tag Tag) (int, MessageRejectError) + func (m FieldMap) GetString(tag Tag) (string, 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 FieldGroupWriter) FieldMap + func (m FieldMap) SetInt(tag Tag, value int) FieldMap + func (m FieldMap) SetString(tag Tag, value string) 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 + Clone func() GroupItem + Read func(TagValues) (TagValues, error) + Tag func() Tag + func GroupElement(tag Tag) GroupItem + type GroupTemplate []GroupItem + func (gt GroupTemplate) Clone() GroupTemplate + type Header struct + func (h *Header) Init() + type IncorrectFormatForSetting struct + Err error + Setting string + Value string + func (e IncorrectFormatForSetting) Error() string + type Initiator struct + func NewInitiator(app Application, storeFactory MessageStoreFactory, appSettings *Settings, ...) (*Initiator, error) + func (i *Initiator) Start() (err 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 Messagable interface + ToMessage func() Message + type Message struct + Body Body + Header Header + ReceiveTime time.Time + Trailer Trailer + func NewMessage() (m Message) + func ParseMessage(rawMessage []byte) (Message, error) + func (m *Message) Build() ([]byte, error) + func (m *Message) String() string + func (m Message) ToMessage() Message + type MessageRejectError interface + IsBusinessReject func() bool + RefTagID func() *Tag + RejectReason func() int + func ConditionallyRequiredFieldMissing(tag Tag) MessageRejectError + func IncorrectDataFormatForValue(tag Tag) MessageRejectError + func InvalidMessageType() MessageRejectError + func InvalidTagNumber(tag Tag) MessageRejectError + func NewBusinessMessageRejectError(err string, rejectReason int, refTagID *Tag) MessageRejectError + func NewMessageRejectError(err string, rejectReason int, refTagID *Tag) MessageRejectError + func RequiredTagMissing(tag Tag) MessageRejectError + func TagNotDefinedForThisMessageType(tag Tag) MessageRejectError + func TagSpecifiedWithoutAValue(tag Tag) MessageRejectError + func UnsupportedMessageType() 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 + Close func() error + CreationTime func() time.Time + GetMessages func(beginSeqNum, endSeqNum int) ([][]byte, error) + IncrNextSenderMsgSeqNum func() error + IncrNextTargetMsgSeqNum func() error + NextSenderMsgSeqNum func() int + NextTargetMsgSeqNum func() int + Refresh func() error + Reset func() error + SaveMessage func(seqNum int, msg []byte) error + SetNextSenderMsgSeqNum func(next int) error + SetNextTargetMsgSeqNum func(next int) error + type MessageStoreFactory interface + Create func(sessionID SessionID) (MessageStore, error) + func NewFileStoreFactory(settings *Settings) MessageStoreFactory + func NewMemoryStoreFactory() MessageStoreFactory + func NewSQLStoreFactory(settings *Settings) MessageStoreFactory + type RejectLogon struct + Text string + func (RejectLogon) IsBusinessReject() bool + func (RejectLogon) RefTagID() *Tag + func (RejectLogon) RejectReason() int + func (e RejectLogon) Error() string + type RepeatingGroup struct + func NewRepeatingGroup(tag Tag, template GroupTemplate) *RepeatingGroup + func (f *RepeatingGroup) Add() Group + func (f *RepeatingGroup) Read(tv TagValues) (TagValues, error) + func (f RepeatingGroup) Clone() GroupItem + func (f RepeatingGroup) Get(i int) Group + func (f RepeatingGroup) Len() int + func (f RepeatingGroup) Tag() Tag + func (f RepeatingGroup) Write() TagValues + type SessionID struct + BeginString string + Qualifier string + SenderCompID string + SenderLocationID string + SenderSubID string + TargetCompID string + TargetLocationID string + TargetSubID string + func (s SessionID) IsFIXT() bool + func (s SessionID) String() string + type SessionSettings struct + func NewSessionSettings() *SessionSettings + func (s *SessionSettings) DurationSetting(setting string) (val time.Duration, err error) + func (s *SessionSettings) HasSetting(setting string) bool + func (s *SessionSettings) Init() + func (s *SessionSettings) IntSetting(setting string) (val int, err 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 + type TagValue struct + func (tv TagValue) String() string + type TagValues []TagValue + type Trailer struct + func (t *Trailer) Init()
Go to main page