centrifugo

Documentation

Index

• Variables
• type Centrifugo
  • func (c *Centrifugo) Publish(ctx context.Context, channel string, msg interface{}) error
  • func (c *Centrifugo) SendToAdminCentrifugo(channel string, order *billingpb.Order, message string) error
  • func (c *Centrifugo) SendToMerchantTestingCentrifugo(channel string, order *billingpb.Order, testCase string, ...) error
  • func (c *Centrifugo) SendToUserCentrifugo(channel string, order *billingpb.Order) error
• type CentrifugoInterface
  • func NewCentrifugo(cfg *config.Centrifugo, httpClient *http.Client) CentrifugoInterface

Variables

var (
	OrderAlphabetStatuses = map[int32]string{
		recurringpb.OrderStatusNew:                         "NEW",
		recurringpb.OrderStatusPaymentSystemCreate:         "IN_PROGRESS",
		recurringpb.OrderStatusPaymentSystemRejectOnCreate: "DECLINED",
		recurringpb.OrderStatusPaymentSystemReject:         "DECLINED",
		recurringpb.OrderStatusPaymentSystemComplete:       "COMPLETED",
		recurringpb.OrderStatusProjectInProgress:           "COMPLETED",
		recurringpb.OrderStatusProjectComplete:             "COMPLETED",
		recurringpb.OrderStatusProjectPending:              "COMPLETED",
		recurringpb.OrderStatusProjectReject:               "REFUNDED",
		recurringpb.OrderStatusRefund:                      "REFUNDED",
		recurringpb.OrderStatusChargeback:                  "CHARGEBACK_RESOLVED",
		recurringpb.OrderStatusPaymentSystemDeclined:       "DECLINED",
		recurringpb.OrderStatusPaymentSystemCanceled:       "CANCELLED",
	}
)

Types

type Centrifugo

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

func (*Centrifugo) Publish

func (c *Centrifugo) Publish(ctx context.Context, channel string, msg interface{}) error

func (*Centrifugo) SendToAdminCentrifugo

func (c *Centrifugo) SendToAdminCentrifugo(channel string, order *billingpb.Order, message string) error

func (*Centrifugo) SendToMerchantTestingCentrifugo

func (c *Centrifugo) SendToMerchantTestingCentrifugo(
	channel string,
	order *billingpb.Order,
	testCase string,
	request *common.Request,
	response *http.Response,
) error

func (*Centrifugo) SendToUserCentrifugo

func (c *Centrifugo) SendToUserCentrifugo(channel string, order *billingpb.Order) error

type CentrifugoInterface

type CentrifugoInterface interface {
	Publish(context.Context, string, interface{}) error
	SendToUserCentrifugo(channel string, order *billingpb.Order) error
	SendToAdminCentrifugo(channel string, order *billingpb.Order, message string) error
	SendToMerchantTestingCentrifugo(channel string, order *billingpb.Order, testCase string, request *common.Request, response *http.Response) error
}

func NewCentrifugo

func NewCentrifugo(cfg *config.Centrifugo, httpClient *http.Client) CentrifugoInterface