grpc

Documentation

Index

• Constants
• type Daemon
  • func NewDaemon(ctx context.Context, workDir string, storages *storage.Storages, t *testing.T, ...) (*Daemon, error)
  • func (d *Daemon) APIClient() *grpc.Server
  • func (d *Daemon) Clients() []*client.Client
  • func (d *Daemon) ClientsCount() int
  • func (d *Daemon) MessagesClient() *grpc.Server
  • func (d *Daemon) StartAgents(portRsList []PortRs, useSSL bool) error
  • func (d *Daemon) StartAllAgents() error
  • func (d *Daemon) StartAllAgentsUsingSSL() error
  • func (d *Daemon) Stop()
• type PortRs

Constants

const (
	TestGrpcMessagesPort = "10000"
	TestGrpcAPIPort      = "10001"
)

Types

type Daemon

type Daemon struct {
	MessagesServer *server.MessagesServer
	APIServer      *api.Server
	// contains filtered or unexported fields
}

func NewDaemon

func NewDaemon(ctx context.Context, workDir string, storages *storage.Storages, t *testing.T,
	logger *logrus.Logger) (*Daemon, error)

func (*Daemon) APIClient

func (d *Daemon) APIClient() *grpc.Server

func (*Daemon) Clients

func (d *Daemon) Clients() []*client.Client

func (*Daemon) ClientsCount

func (d *Daemon) ClientsCount() int

func (*Daemon) MessagesClient

func (d *Daemon) MessagesClient() *grpc.Server

func (*Daemon) StartAgents

func (d *Daemon) StartAgents(portRsList []PortRs, useSSL bool) error

func (*Daemon) StartAllAgents

func (d *Daemon) StartAllAgents() error

func (*Daemon) StartAllAgentsUsingSSL

func (d *Daemon) StartAllAgentsUsingSSL() error

func (*Daemon) Stop

func (d *Daemon) Stop()

type PortRs

type PortRs struct {
	Port string
	Rs   string
}