grpc

Documentation

Overview

Copyright (c) Ultraviolet SPDX-License-Identifier: Apache-2.0

Package grpc contains implementation of kit service gRPC API.

Copyright (c) Ultraviolet SPDX-License-Identifier: Apache-2.0

Index

• Variables
• func NewServer(incoming chan *manager.ClientStreamMessage, svc Service) manager.ManagerServiceServer
• type ManagerClient
  • func NewClient(stream pkgmanager.ManagerService_ProcessClient, svc manager.Service, ...) ManagerClient
  • func (client ManagerClient) Process(ctx context.Context, cancel context.CancelFunc) error
• type Service

Variables

var (
	ErrUnexpectedMsg = errors.New("unknown message type")
)

Functions

func NewServer

func NewServer(incoming chan *manager.ClientStreamMessage, svc Service) manager.ManagerServiceServer

NewServer returns new AuthServiceServer instance.

Types

type ManagerClient

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

func NewClient

func NewClient(stream pkgmanager.ManagerService_ProcessClient, svc manager.Service, responses chan *pkgmanager.ClientStreamMessage) ManagerClient

NewClient returns new gRPC client instance.

func (ManagerClient) Process

func (client ManagerClient) Process(ctx context.Context, cancel context.CancelFunc) error

type Service

type Service interface {
	Run(ipAddress string, runReqChan chan *manager.ServerStreamMessage, authInfo credentials.AuthInfo)
}