Documentation
¶
Index ¶
- Variables
- type Client
- type ClientInfoAuthInfo
- type ConnectedClient
- type GRPCClientSettings
- type GRPCServerSettings
- type Handler
- type Server
- func (s *Server) Call(context context.Context, pbRequest *protobuf.Request) (*protobuf.Response, error)
- func (s *Server) CanDeliverTo(address *eps.Address) bool
- func (s *Server) DeliverRequest(request *eps.Request) (*eps.Response, error)
- func (s *Server) ServerCall(server protobuf.EPS_ServerCallServer) error
- func (s *Server) Start() error
- func (s *Server) Stop() error
- type VerifyCredentials
Constants ¶
This section is empty.
Variables ¶
View Source
var GRPCClientSettingsForm = forms.Form{ Fields: []forms.Field{ { Name: "tls", Validators: []forms.Validator{ forms.IsStringMap{ Form: &tls.TLSSettingsForm, }, }, }, }, }
View Source
var GRPCServerSettingsForm = forms.Form{ Fields: []forms.Field{ { Name: "bind_address", Validators: []forms.Validator{ forms.IsOptional{Default: "localhost:4444"}, forms.IsString{}, }, }, { Name: "tls", Validators: []forms.Validator{ forms.IsStringMap{ Form: &tls.TLSSettingsForm, }, }, }, }, }
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func MakeClient ¶
func MakeClient(settings *GRPCClientSettings, directory eps.Directory) (*Client, error)
func (*Client) SendRequest ¶
type ClientInfoAuthInfo ¶
type ClientInfoAuthInfo struct {
credentials.AuthInfo
ClientInfo *eps.ClientInfo
}
type ConnectedClient ¶
type ConnectedClient struct {
CallServer protobuf.EPS_ServerCallServer
Stop chan bool
Info *eps.ClientInfo
// contains filtered or unexported fields
}
func (*ConnectedClient) DeliverRequest ¶
type GRPCClientSettings ¶
type GRPCClientSettings struct {
TLS *tls.TLSSettings `json:"tls"`
Enabled bool `json:"enabled"`
}
Settings for the gRPC client
type GRPCServerSettings ¶
type GRPCServerSettings struct {
TLS *tls.TLSSettings `json:"tls"`
BindAddress string `json:"bind_address"`
Enabled bool `json:"enabled"`
}
Settings for the gRPC server
type Server ¶
type Server struct {
protobuf.UnimplementedEPSServer
// contains filtered or unexported fields
}
func MakeServer ¶
func (*Server) DeliverRequest ¶
func (*Server) ServerCall ¶
func (s *Server) ServerCall(server protobuf.EPS_ServerCallServer) error
type VerifyCredentials ¶
type VerifyCredentials struct {
credentials.TransportCredentials
ClientInfo *eps.ClientInfo
// contains filtered or unexported fields
}
func (VerifyCredentials) ClientHandshake ¶
func (VerifyCredentials) ServerHandshake ¶
func (c VerifyCredentials) ServerHandshake(conn net.Conn) (net.Conn, credentials.AuthInfo, error)
Source Files
Click to show internal directories.
Click to hide internal directories.