mysql

package
v0.0.0-...-2746f0d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2017 License: MIT Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewLockedMessage 

func NewLockedMessage(message interface{}, messageType int32, dbConnection *sql.DB, dbTransaction *sql.Tx, capOptions *cap.CapOptions) cap.ILockedMessage

NewLockedMessage ...

func NewLockedMessages 

func NewLockedMessages(messageType int32, dbConnection *sql.DB, dbTransaction *sql.Tx, capOptions *cap.CapOptions) cap.ILockedMessages

NewLockedMessages ...

func NewPublisher 

func NewPublisher(options *cap.CapOptions) cap.IPublisher

NewPublisher ..

func NewStorageConnection 

func NewStorageConnection(options *cap.CapOptions) cap.IStorageConnection

NewStorageConnection ...

func NewStorageTransaction 

func NewStorageTransaction(options *cap.CapOptions) (cap.IStorageTransaction, error)

NewStorageTransaction ...

Types

type LockedMessage 

type LockedMessage struct {
	// contains filtered or unexported fields
}

LockedMessage ...

func (*LockedMessage) ChangeState 

func (message *LockedMessage) ChangeState(state cap.IState) error

ChangeState ...

func (*LockedMessage) Commit 

func (message *LockedMessage) Commit() error

Commit ...

func (*LockedMessage) Dispose 

func (message *LockedMessage) Dispose()

Dispose ...

func (*LockedMessage) GetMessage 

func (message *LockedMessage) GetMessage() interface{}

GetMessage ...

func (*LockedMessage) GetMessageType 

func (message *LockedMessage) GetMessageType() int32

GetMessageType ...

func (*LockedMessage) Prepare 

func (message *LockedMessage) Prepare(query string) (stmt interface{}, err error)

Prepare ...

func (*LockedMessage) Rollback 

func (message *LockedMessage) Rollback() error

Rollback ...

type LockedMessages 

type LockedMessages struct {
	// contains filtered or unexported fields
}

LockedMessages ...

func (*LockedMessages) AppendMessage 

func (message *LockedMessages) AppendMessage(i interface{})

AppendMessage ...

func (*LockedMessages) ChangeStates 

func (message *LockedMessages) ChangeStates(state cap.IState) error

ChangeStates ...

func (*LockedMessages) Commit 

func (message *LockedMessages) Commit() error

Commit ...

func (*LockedMessages) Dispose 

func (message *LockedMessages) Dispose()

Dispose ...

func (*LockedMessages) GetMessageType 

func (message *LockedMessages) GetMessageType() int32

GetMessageType ...

func (*LockedMessages) GetMessages 

func (message *LockedMessages) GetMessages() []cap.ILockedMessage

GetMessages ...

func (*LockedMessages) Prepare 

func (message *LockedMessages) Prepare(query string) (stmt interface{}, err error)

Prepare ...

func (*LockedMessages) Rollback 

func (message *LockedMessages) Rollback() error

Rollback ...

type MySqlFetchedMessage 

type MySqlFetchedMessage struct {
	// contains filtered or unexported fields
}

MySqlFetchedMessage ...

func NewFetchedMessage 

func NewFetchedMessage(_messageId int, _messageType int, _dbConnection *sql.DB, _dbTransaction *sql.Tx) *MySqlFetchedMessage

NewFetchedMessage ...

func (*MySqlFetchedMessage) Dispose 

func (fetchedMessage *MySqlFetchedMessage) Dispose() error

Dispose ...

func (*MySqlFetchedMessage) GetMessageId 

func (fetchedMessage *MySqlFetchedMessage) GetMessageId() (messageId int)

GetMessageId ...

func (*MySqlFetchedMessage) GetMessageType 

func (fetchedMessage *MySqlFetchedMessage) GetMessageType() (messageType int)

GetMessageType ...

func (*MySqlFetchedMessage) RemoveFromQueue 

func (fetchedMessage *MySqlFetchedMessage) RemoveFromQueue() error

RemoveFromQueue ...

func (*MySqlFetchedMessage) Requeue 

func (fetchedMessage *MySqlFetchedMessage) Requeue() error

Requeue ...

type MySqlPublisher 

type MySqlPublisher struct {
	Options          *cap.CapOptions
	IsCapOpenedTrans bool
	// contains filtered or unexported fields
}

MySqlPublisher ..

func (*MySqlPublisher) Publish 

func (publisher *MySqlPublisher) Publish(descriptors []*cap.MessageDescriptor, connection interface{}, transaction interface{}) error

Publish ..

func (*MySqlPublisher) PublishOne 

func (publisher *MySqlPublisher) PublishOne(name string, content interface{}, connection interface{}, transaction interface{}) error

PublishOne ...

type MySqlStorageConnection 

type MySqlStorageConnection struct {
	Options *cap.CapOptions
	// contains filtered or unexported fields
}

MySqlStorageConnection ...

func (MySqlStorageConnection) BeginTransaction 

func (connection MySqlStorageConnection) BeginTransaction(dbConnection *sql.DB) (*sql.Tx, error)

BeginTransaction ...

func (*MySqlStorageConnection) CreateTransaction 

func (connection *MySqlStorageConnection) CreateTransaction() (cap.IStorageTransaction, error)

CreateTransaction ...

func (*MySqlStorageConnection) FetchNextMessage 

func (connection *MySqlStorageConnection) FetchNextMessage() (cap.IFetchedMessage, error)

FetchNextMessage ...

func (*MySqlStorageConnection) GetFailedLockedMessages 

func (connection *MySqlStorageConnection) GetFailedLockedMessages(messageType int32) (cap.ILockedMessages, error)

GetFailedLockedMessages ...

func (*MySqlStorageConnection) GetFailedPublishedLockedMessages 

func (connection *MySqlStorageConnection) GetFailedPublishedLockedMessages(conn *sql.DB, transaction *sql.Tx) (cap.ILockedMessages, error)

GetFailedPublishedLockedMessages ...

func (*MySqlStorageConnection) GetFailedPublishedMessages 

func (connection *MySqlStorageConnection) GetFailedPublishedMessages() ([]*cap.CapPublishedMessage, error)

GetFailedPublishedMessages ...

func (*MySqlStorageConnection) GetFailedReceivedLockedMessages 

func (connection *MySqlStorageConnection) GetFailedReceivedLockedMessages(conn *sql.DB, transaction *sql.Tx) (cap.ILockedMessages, error)

GetFailedReceivedMessages ...

func (*MySqlStorageConnection) GetFailedReceivedMessages 

func (connection *MySqlStorageConnection) GetFailedReceivedMessages() ([]*cap.CapReceivedMessage, error)

GetFailedReceivedMessages ...

func (*MySqlStorageConnection) GetNextLockedMessageToBeEnqueued 

func (connection *MySqlStorageConnection) GetNextLockedMessageToBeEnqueued(messageType int32) (cap.ILockedMessage, error)

GetNextLockedMessageToBeEnqueued ...

func (*MySqlStorageConnection) GetNextPublishedMessageToBeEnqueued 

func (connection *MySqlStorageConnection) GetNextPublishedMessageToBeEnqueued() (*cap.CapPublishedMessage, error)

GetNextPublishedMessageToBeEnqueued ...

func (*MySqlStorageConnection) GetNextReceviedMessageToBeEnqueued 

func (connection *MySqlStorageConnection) GetNextReceviedMessageToBeEnqueued() (*cap.CapReceivedMessage, error)

GetNextReceviedMessageToBeEnqueued ..

func (*MySqlStorageConnection) GetPublishedMessage 

func (connection *MySqlStorageConnection) GetPublishedMessage(id int) (*cap.CapPublishedMessage, error)

GetPublishedMessage ...

func (*MySqlStorageConnection) GetReceivedMessage 

func (connection *MySqlStorageConnection) GetReceivedMessage(id int) (*cap.CapReceivedMessage, error)

GetReceivedMessage ...

func (MySqlStorageConnection) OpenDbConnection 

func (connection MySqlStorageConnection) OpenDbConnection() (*sql.DB, error)

OpenDbConnection ...

func (*MySqlStorageConnection) StoreReceivedMessage 

func (connection *MySqlStorageConnection) StoreReceivedMessage(message *cap.CapReceivedMessage) error

StoreReceivedMessage ...

type MySqlStorageTransaction 

type MySqlStorageTransaction struct {
	Options       *cap.CapOptions
	DbConnection  *sql.DB
	DbTransaction *sql.Tx
}

MySqlStorageTransaction ...

func (*MySqlStorageTransaction) Commit 

func (transaction *MySqlStorageTransaction) Commit() error

Commit ...

func (*MySqlStorageTransaction) Dispose 

func (transaction *MySqlStorageTransaction) Dispose()

Dispose ...

func (*MySqlStorageTransaction) EnqueuePublishedMessage 

func (transaction *MySqlStorageTransaction) EnqueuePublishedMessage(message *cap.CapPublishedMessage) error

EnqueuePublishedMessage ...

func (*MySqlStorageTransaction) EnqueueReceivedMessage 

func (transaction *MySqlStorageTransaction) EnqueueReceivedMessage(message *cap.CapReceivedMessage) error

EnqueueReceivedMessage ...

func (*MySqlStorageTransaction) UpdatePublishedMessage 

func (transaction *MySqlStorageTransaction) UpdatePublishedMessage(message *cap.CapPublishedMessage) error

UpdatePublishedMessage ...

func (*MySqlStorageTransaction) UpdateReceivedMessage 

func (transaction *MySqlStorageTransaction) UpdateReceivedMessage(message *cap.CapReceivedMessage) error

UpdateReceivedMessage ...

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.