pkg

Documentation

Index

• func InServiceDefList(list []*proto.ServiceDefinition, name string) bool
• func InServiceList(list []*Service, name string) bool
• func WithServerUnaryInterceptor(procfile string) grpc.ServerOption
• type PrefixWriter
  • func (w PrefixWriter) Write(p []byte) (n int, err error)
• type Service
  • func NewServiceFromDef(s *proto.ServiceDefinition) *Service
  • func (s *Service) AddListener(ch chan []byte)
  • func (s *Service) Clone() *Service
  • func (s *Service) RemoveListener(ch chan []byte)
  • func (s *Service) Start(killChan <-chan os.Signal) error

Functions

func InServiceDefList

func InServiceDefList(list []*proto.ServiceDefinition, name string) bool

func InServiceList

func InServiceList(list []*Service, name string) bool

func WithServerUnaryInterceptor

func WithServerUnaryInterceptor(procfile string) grpc.ServerOption

Types

type PrefixWriter

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

func (PrefixWriter) Write

func (w PrefixWriter) Write(p []byte) (n int, err error)

type Service

type Service struct {
	Name     string
	Command  string
	StopChan chan os.Signal
	// contains filtered or unexported fields
}

func NewServiceFromDef

func NewServiceFromDef(s *proto.ServiceDefinition) *Service

func (*Service) AddListener

func (s *Service) AddListener(ch chan []byte)

func (*Service) Clone

func (s *Service) Clone() *Service

func (*Service) RemoveListener

func (s *Service) RemoveListener(ch chan []byte)

func (*Service) Start

func (s *Service) Start(killChan <-chan os.Signal) error