queue

package
v2.0.6+incompatible Latest Latest
Warning

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

 Go to latest Published: Apr 9, 2019 License: MIT Imports: 26 Imported by: 2

Documentation

Overview

Package queue implements Temporal's various queue consumers and publishers

Index

Constants

This section is empty.

Variables

View Source 
var (

	// IpfsPinQueue is a queue used for ipfs pins
	IpfsPinQueue Queue = "ipfs-pin-queue"
	// IpfsClusterPinQueue is a queue used for ipfs cluster pins
	IpfsClusterPinQueue Queue = "ipfs-cluster-add-queue"
	// EmailSendQueue is a queue used to handle sending email messages
	EmailSendQueue Queue = "email-send-queue"
	// IpnsEntryQueue is a queue used to handle ipns entry creation
	IpnsEntryQueue Queue = "ipns-entry-queue"
	// IpfsKeyCreationQueue is a queue used to handle ipfs key creation
	IpfsKeyCreationQueue Queue = "ipfs-key-creation-queue"
	// EthPaymentConfirmationQueue is a queue used to handle ethereum based payment confirmations
	EthPaymentConfirmationQueue Queue = "eth-payment-confirmation-queue"
	// DashPaymentConfirmationQueue is a queue used to handle confirming dash payments
	DashPaymentConfirmationQueue Queue = "dash-payment-confirmation-queue"
	// AdminEmail is the email used to notify RTrade about any critical errors
	AdminEmail = "temporal.reports@rtradetechnologies.com"
	// IpfsPinFailedContent is a to-be formatted message sent on IPFS pin failures
	IpfsPinFailedContent = "Pin failed for content hash %s on IPFS network %s, for reason %s"
	// IpfsPinFailedSubject is a subject for IPFS pin failed messages
	IpfsPinFailedSubject = "IPFS Pin Failed"
	// IpfsFileFailedContent is a to be formatted message sent on ipfs add failures
	IpfsFileFailedContent = "IPFS File Add Failed for object name %s on IPFS network %s"
	// IpfsFileFailedSubject is a subject for ipfs file add fails
	IpfsFileFailedSubject = "IPFS File Add Failed"
	// IpfsPrivateNetworkUnauthorizedSubject is a subject whenever someone tries to access a bad private network
	IpfsPrivateNetworkUnauthorizedSubject = "Unauthorized access to IPFS private network"
	// IpfsInitializationFailedSubject is a subject used when connecting to ipfs fails
	IpfsInitializationFailedSubject = "Connection to IPFS failed"
	// IpnsEntryFailedSubject is a subject sent upon IPNS failures
	IpnsEntryFailedSubject = "IPNS Entry Creation Failed"
	// IpnsEntryFailedContent is the content used when sending an email for IPNS entry creation failures
	IpnsEntryFailedContent = "IPNS Entry creation failed for content hash %s using key %s for reason %s"
	// PaymentConfirmationFailedSubject is a subject used when payment confirmations fail
	PaymentConfirmationFailedSubject = "Payment Confirmation Failed"
	// PaymentConfirmationFailedContent is a content used when a payment confirmation failure occurs
	PaymentConfirmationFailedContent = "Payment failed for content hash %s with error %s"
	// ErrReconnect is an error emitted when a protocol connection error occurs
	// It is used to signal reconnect of queue consumers and publishers
	ErrReconnect = "protocol connection error, reconnect"
)

Functions

This section is empty.

Types

type DashPaymenConfirmation 

type DashPaymenConfirmation struct {
	UserName         string `json:"user_name"`
	PaymentForwardID string `json:"payment_forward_id"`
	PaymentNumber    int64  `json:"payment_number"`
}

DashPaymenConfirmation is a message used to signal processing of a dash payment

type EmailSend 

type EmailSend struct {
	Subject     string   `json:"subject"`
	Content     string   `json:"content"`
	ContentType string   `json:"content_type"`
	UserNames   []string `json:"user_names"`
	Emails      []string `json:"emails,omitempty"`
}

EmailSend is a helper struct used to contained formatted content ot send as an email

type EthPaymentConfirmation 

type EthPaymentConfirmation struct {
	UserName      string `json:"user_name"`
	PaymentNumber int64  `json:"payment_number"`
}

EthPaymentConfirmation is a message used to confirm an ethereum based payment

type IPFSClusterPin 

type IPFSClusterPin struct {
	CID              string  `json:"cid"`
	NetworkName      string  `json:"network_name"`
	UserName         string  `json:"user_name"`
	HoldTimeInMonths int64   `json:"hold_time_in_months"`
	Size             int64   `json:"size"`
	CreditCost       float64 `json:"credit_cost"`
}

IPFSClusterPin is a queue message used when sending a message to the cluster to pin content

type IPFSKeyCreation 

type IPFSKeyCreation struct {
	UserName    string  `json:"user_name"`
	Name        string  `json:"name"`
	Type        string  `json:"type"`
	Size        int     `json:"size"`
	NetworkName string  `json:"network_name"`
	CreditCost  float64 `json:"credit_cost"`
}

IPFSKeyCreation is a message used for processing key creation only supported for the public IPFS network at the moment

type IPFSPin 

type IPFSPin struct {
	CID              string  `json:"cid"`
	NetworkName      string  `json:"network_name"`
	UserName         string  `json:"user_name"`
	HoldTimeInMonths int64   `json:"hold_time_in_months"`
	CreditCost       float64 `json:"credit_cost"`
	Size             int64   `json:"size"`
	JWT              string  `json:"jwt,omitempty"`
}

IPFSPin is a struct used when sending pin request

type IPNSEntry 

type IPNSEntry struct {
	CID         string        `json:"cid"`
	LifeTime    time.Duration `json:"life_time"`
	TTL         time.Duration `json:"ttl"`
	Resolve     bool          `json:"resolve"`
	Key         string        `json:"key"`
	UserName    string        `json:"user_name"`
	NetworkName string        `json:"network_name"`
	CreditCost  float64       `json:"credit_cost"`
}

IPNSEntry is used to hold relevant information needed to process IPNS entry creation requests

type IPNSUpdate 

type IPNSUpdate struct {
	CID         string  `json:"content_hash"`
	IPNSHash    string  `json:"ipns_hash"`
	LifeTime    string  `json:"life_time"`
	TTL         string  `json:"ttl"`
	Key         string  `json:"key"`
	Resolve     bool    `json:"resolve"`
	UserName    string  `json:"user_name"`
	NetworkName string  `json:"network_name"`
	CreditCost  float64 `json:"credit_cost"`
}

IPNSUpdate is our message for the ipns update queue

type Manager 

type Manager struct {
	ErrCh        chan *amqp.Error
	QueueName    Queue
	ExchangeName string
	// contains filtered or unexported fields
}

Manager is a helper struct to interact with rabbitmq

func New 

func New(queue Queue, url string, publish, devMode bool, cfg *config.TemporalConfig, logger *zap.SugaredLogger) (*Manager, error)

New is used to instantiate a new connection to rabbitmq as a publisher or consumer

func (*Manager) Close 

func (qm *Manager) Close() error

Close is used to close our queue resources

func (*Manager) ConsumeMessages 

func (qm *Manager) ConsumeMessages(ctx context.Context, wg *sync.WaitGroup, db *gorm.DB, cfg *config.TemporalConfig) error

ConsumeMessages is used to consume messages that are sent to the queue Question, do we really want to ack messages that fail to be processed? Perhaps the error was temporary, and we allow it to be retried?

func (*Manager) ProccessIPFSPins 

func (qm *Manager) ProccessIPFSPins(ctx context.Context, wg *sync.WaitGroup, msgs <-chan amqp.Delivery) error

ProccessIPFSPins is used to process IPFS pin requests

func (*Manager) ProcessIPFSClusterPins 

func (qm *Manager) ProcessIPFSClusterPins(ctx context.Context, wg *sync.WaitGroup, msgs <-chan amqp.Delivery) error

ProcessIPFSClusterPins is used to process messages sent to rabbitmq requesting be pinned to our cluster

func (*Manager) ProcessIPFSKeyCreation 

func (qm *Manager) ProcessIPFSKeyCreation(ctx context.Context, wg *sync.WaitGroup, msgs <-chan amqp.Delivery) error

ProcessIPFSKeyCreation is used to create IPFS keys

func (*Manager) ProcessIPNSEntryCreationRequests 

func (qm *Manager) ProcessIPNSEntryCreationRequests(ctx context.Context, wg *sync.WaitGroup, msgs <-chan amqp.Delivery) error

ProcessIPNSEntryCreationRequests is used to process IPNS entry creation requests

func (*Manager) ProcessMailSends 

func (qm *Manager) ProcessMailSends(ctx context.Context, wg *sync.WaitGroup, db *gorm.DB, msgs <-chan amqp.Delivery) error

ProcessMailSends is a function used to process mail send queue messages

func (*Manager) PublishMessage 

func (qm *Manager) PublishMessage(body interface{}) error

PublishMessage is used to produce messages that are sent to the queue, with a worker queue (one consumer)

func (*Manager) RegisterConnectionClosure 

func (qm *Manager) RegisterConnectionClosure()

RegisterConnectionClosure is used to register a channel which we may receive connection level errors. This covers all channel, and connection errors.

type Queue 

type Queue string

Queue is a typed string used to declare the various queue names

func (Queue) String 

func (qt Queue) String() string

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.