services

Documentation

Index

• type CampaignService
  • func NewCampaignService(db *storm.DB) *CampaignService
  • func (s *CampaignService) Save(data *entity.Campaign) error
• type CampaignServiceSave
• type OrderService
  • func NewOrderService(db *storm.DB) *OrderService
  • func (s *OrderService) Save(data *entity.Order) error
• type OrderServiceSave
• type Ticker
• type TickerObserver
• type TickerService
  • func NewTickerService() *TickerService
  • func (s *TickerService) AddObserver(channel string, observer TickerObserver)
  • func (s *TickerService) Send(event *Ticker)

Types

type CampaignService

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

CampaignService struct

func NewCampaignService

func NewCampaignService(db *storm.DB) *CampaignService

NewCampaignService constructor

func (*CampaignService) Save

func (s *CampaignService) Save(data *entity.Campaign) error

Save Campaign

type CampaignServiceSave

type CampaignServiceSave interface {
	Save(data *entity.Campaign) error
}

CampaignServiceSave interface

type OrderService

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

OrderService struct

func NewOrderService

func NewOrderService(db *storm.DB) *OrderService

NewOrderService constructor

func (*OrderService) Save

func (s *OrderService) Save(data *entity.Order) error

Save Order

type OrderServiceSave

type OrderServiceSave interface {
	Save(data *entity.Order) error
}

OrderServiceSave interface

type Ticker

type Ticker struct {
	*exchanges.TickerEvent
	Product string
}

Ticker event

type TickerObserver

type TickerObserver func(event *Ticker)

TickerObserver alias

type TickerService

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

TickerService struc

func NewTickerService

func NewTickerService() *TickerService

NewTickerService func

func (*TickerService) AddObserver

func (s *TickerService) AddObserver(channel string, observer TickerObserver)

AddObserver to service

func (*TickerService) Send

func (s *TickerService) Send(event *Ticker)

Send Ticker event to service