grpc

package

v0.0.3 Latest Latest Go to latest Published: Oct 20, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Details

View Source

const (
	CERTIFICATE_MOUTH_PATH = "/etc/auth/"
	CERTIFICATE_KEY        = "crt"
	PRIVATE_KEY            = "pk"
)

View Source

var (
	HOST string = os.Getenv("AUTOPI_HOSTNAME")
	PORT string = os.Getenv("AUTOPI_PORT")
)

func InitRemoteWorkProcessorGrpcClient()

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

func NewGrpcClientMetadata(host string, port string) *GrpcClientMetadata

func (gm *GrpcClientMetadata) BlockWhenDialing() *GrpcClientMetadata

func (gm *GrpcClientMetadata) WithClientCertificate() *GrpcClientMetadata

type RemoteWorkProcessorGrpcClient struct {
	sync.Mutex
	// contains filtered or unexported fields
}

var (
	Client RemoteWorkProcessorGrpcClient
)

func (gc *RemoteWorkProcessorGrpcClient) Receive() <-chan *pb.ServerMessage

func (gc *RemoteWorkProcessorGrpcClient) Send(op *pb.ClientMessage)

Path	Synopsis
processors