Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FileWriter ¶
type FileWriter struct {
// contains filtered or unexported fields
}
func (*FileWriter) Close ¶
func (fw *FileWriter) Close() error
func (*FileWriter) Write ¶
func (fw *FileWriter) Write(txn *types.Transaction) (*types.Transaction, error)
type PubSubWriter ¶
type PubSubWriter struct {
// contains filtered or unexported fields
}
func (*PubSubWriter) Close ¶
func (writer *PubSubWriter) Close() error
func (*PubSubWriter) Write ¶
func (writer *PubSubWriter) Write(txn *types.Transaction) (*types.Transaction, error)
type TxnWriter ¶
type TxnWriter interface { Init(*t.Config) error Write(*types.Transaction) (*types.Transaction, error) Close() error }
func NewFileWriter ¶
func NewFileWriter() TxnWriter
func NewPubSubWriter ¶
func NewPubSubWriter() TxnWriter
Click to show internal directories.
Click to hide internal directories.