Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CDCService ¶
type CDCService struct {
// contains filtered or unexported fields
}
func NewCDCService ¶
func NewCDCService(client TransactionLogClient) *CDCService
func (*CDCService) ChangeDataCapture ¶
func (service *CDCService) ChangeDataCapture(bytes []byte) error
type NotificationService ¶
type NotificationService struct {
// contains filtered or unexported fields
}
func NewNotificationService ¶
func NewNotificationService(topic, address string) *NotificationService
func (*NotificationService) Consume ¶
func (s *NotificationService) Consume(handler func([]byte) error)
type TransactionLogClient ¶
type TransactionLogClient interface {
Create(input *dto.TransactionLog) (output *dto.TransactionLog, err error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.