service

Documentation

Index

• type Service
  • func New(c *conf.Config) *Service
  • func (s *Service) Close()
  • func (s *Service) GetOne(ctx context.Context, mid int64) (*model.AccountSummary, error)
  • func (s *Service) Main()
  • func (s *Service) Ping(c context.Context) error
  • func (s *Service) SyncOne(ctx context.Context, mid int64) error
  • func (s *Service) SyncToHBase(ctx context.Context, body Syncable) error
• type Syncable

Types

type Service

type Service struct {
	MemberBinLog           *databus.Databus
	BlockBinLog            *databus.Databus
	PassportBinLog         *databus.Databus
	RelationBinLog         *databus.Databus
	AccountSummaryProducer *databus.Databus
	// contains filtered or unexported fields
}

Service struct

func New

func New(c *conf.Config) *Service

New init

func (*Service) Close

func (s *Service) Close()

Close Service

func (*Service) GetOne

func (s *Service) GetOne(ctx context.Context, mid int64) (*model.AccountSummary, error)

GetOne is

func (*Service) Main

func (s *Service) Main()

Main is

func (*Service) Ping

func (s *Service) Ping(c context.Context) error

Ping Service

func (*Service) SyncOne

func (s *Service) SyncOne(ctx context.Context, mid int64) error

SyncOne is

func (*Service) SyncToHBase

func (s *Service) SyncToHBase(ctx context.Context, body Syncable) error

SyncToHBase is

type Syncable

type Syncable interface {
	Key() (string, error)
	Marshal() (map[string][]byte, error)
}

Syncable is