service

Documentation

Index

• type Service
  • func New(ipcSvc *ipc.Ipc, opts ...options.Option) *Service
  • func (s *Service) Run() <-chan error
  • func (s *Service) Start() context.Context
• type SubjectConstants
  • func NewSubjectConstants() *SubjectConstants

Types

type Service

type Service struct {
	*service.Service

	ErrCh chan error
	// contains filtered or unexported fields
}

func New

func New(ipcSvc *ipc.Ipc, opts ...options.Option) *Service

func (*Service) Run

func (s *Service) Run() <-chan error

func (*Service) Start

func (s *Service) Start() context.Context

type SubjectConstants

type SubjectConstants struct {
	StreamedHeader     string
	StreamedBlock      string
	StreamedTx         string
	StreamedTxLogEvent string
	StreamedTxMemPool  string
	SteramedTraceCall  string
}

func NewSubjectConstants

func NewSubjectConstants() *SubjectConstants