grpc

package

v0.3.0 Latest Latest Go to latest Published: Feb 14, 2019 License: Apache-2.0 Imports: 17 Imported by: 0

Details

View Source

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

This section is empty.

This section is empty.

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

func NewDaemon(ctx context.Context, workDir string, storages *storage.Storages, t *testing.T, logger *logrus.Logger) (*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) error

func (d *Daemon) StartAllAgents() error

func (d *Daemon) Stop()

type PortRs struct {
	Port string
	Rs   string
}