services

Documentation

Index

• type BoardStreamService
  • func NewBoardStreamService(streamStore repositories.BoardStreamStore, boardWS repositories.BoardWS, ...) BoardStreamService
• type RegisterSymbolService
  • func NewRegisterSymbolService(registerSymbolStore repositories.RegisterSymbolStore) RegisterSymbolService
• type TokenService
  • func NewTokenService(tokenStore repositories.TokenStore, security repositories.Security, ...) TokenService

Types

type BoardStreamService

type BoardStreamService interface {
	Start()
	Connect(stream kabuspb.KabusService_GetBoardsStreamingServer) error
}

func NewBoardStreamService

func NewBoardStreamService(streamStore repositories.BoardStreamStore, boardWS repositories.BoardWS, virtual repositories.VirtualSecurity) BoardStreamService

type RegisterSymbolService

type RegisterSymbolService interface {
	CountAll() int
	GetAll() []*kabuspb.RegisterSymbol
	Get(requester string) []*kabuspb.RegisterSymbol
	Add(requester string, symbols []*kabuspb.RegisterSymbol)
	Remove(requester string, symbols []*kabuspb.RegisterSymbol)
}

func NewRegisterSymbolService

func NewRegisterSymbolService(registerSymbolStore repositories.RegisterSymbolStore) RegisterSymbolService

type TokenService

type TokenService interface {
	GetToken(ctx context.Context) (string, error)
	GetExpiredAt() time.Time
	Refresh(ctx context.Context) (string, error)
}

func NewTokenService

func NewTokenService(
	tokenStore repositories.TokenStore,
	security repositories.Security,
	clock repositories.Clock,
	setting repositories.Setting) TokenService