grpc

Documentation

Index

• type ClientConfig
• type Config
• type RAJDSGRPCResolver
  • func ProvideRAJDSGRPCResolver() RAJDSGRPCResolver
  • func (r *RAJDSGRPCResolver) AddHost(name string, value string)
  • func (r *RAJDSGRPCResolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r *RAJDSGRPCResolver) Scheme() string
• type RAJDSGrpcClient
  • func ProvideRAJDSGrpcClient(config ClientConfig) (RAJDSGrpcClient, error)
• type RAJDSGrpcServer
  • func ProvideGRPCServer(config Config, transportCertificate cert.TransportCertificate) (RAJDSGrpcServer, func(), error)
• type WorkerNodeReceiverConfig
• type WorkerNodeReceiverGRPCServer
  • func ProvideWorkerNodeReceiverGRPCServer(config WorkerNodeReceiverConfig) (WorkerNodeReceiverGRPCServer, func(), error)

Types

type ClientConfig

type ClientConfig struct {
	Target        string
	CACertificate cert.WorkerNodeCACertificate
	ServerName    string
}

type Config

type Config struct {
	Port int
}

type RAJDSGRPCResolver

type RAJDSGRPCResolver struct {
	AddressMapper map[string][]string
}

func ProvideRAJDSGRPCResolver

func ProvideRAJDSGRPCResolver() RAJDSGRPCResolver

func (*RAJDSGRPCResolver) AddHost

func (r *RAJDSGRPCResolver) AddHost(name string, value string)

func (*RAJDSGRPCResolver) Build

func (r *RAJDSGRPCResolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*RAJDSGRPCResolver) Scheme

func (r *RAJDSGRPCResolver) Scheme() string

type RAJDSGrpcClient

type RAJDSGrpcClient interface {
	GetConnection() *grpc.ClientConn
}

func ProvideRAJDSGrpcClient

func ProvideRAJDSGrpcClient(config ClientConfig) (RAJDSGrpcClient, error)

type RAJDSGrpcServer

type RAJDSGrpcServer interface {
	Serve()
	GetGRPCServer() *grpc.Server
}

func ProvideGRPCServer

func ProvideGRPCServer(config Config, transportCertificate cert.TransportCertificate) (RAJDSGrpcServer, func(), error)

type WorkerNodeReceiverConfig

type WorkerNodeReceiverConfig Config

type WorkerNodeReceiverGRPCServer

type WorkerNodeReceiverGRPCServer RAJDSGrpcServer

func ProvideWorkerNodeReceiverGRPCServer

func ProvideWorkerNodeReceiverGRPCServer(config WorkerNodeReceiverConfig) (WorkerNodeReceiverGRPCServer, func(), error)