srpc

Mar 12, 2025

Changes in this version

+ func GetClientTlsConfig() *tls.Config

type Client

+ func (client *Client) SetTimeout(timeout time.Duration) error

Apr 29, 2024

Changes in this version

+ func GetNumPanicedCalls() uint64

type Client

+ func (client *Client) IsClosed() bool

+ type ClientI interface

+ Call func(serviceMethod string) (*Conn, error)

+ Close func() error

+ Ping func() error

+ RequestReply func(serviceMethod string, request interface{}, reply interface{}) error

+ SetKeepAlive func(keepalive bool) error

+ SetKeepAlivePeriod func(d time.Duration) error

Sep 4, 2023

Changes in this version

+ var ErrorMissingCA = errors.New("missing CA")

+ func LoadCertificatesFromMetadata(timeout time.Duration, errorIfMissing bool, errorIfExpired bool) (*tls.Certificate, error)

type Client

+ func NewFakeClient(options FakeClientOptions) *Client

+ func (client *Client) IsFromClientResource() bool

+ type FakeClientOptions struct

Sep 1, 2023

Changes in this version

+ func SetDefaultLogger(l log.DebugLogger)

Oct 5, 2022

Changes in this version

+ var ErrorAccessToMethodDenied = errors.New("access to method denied")

+ var ErrorBadCertificate = errors.New("bad certificate")

+ var ErrorCloseClient = errors.New("close client")

+ var ErrorConnectionRefused = errors.New("connection refused")

+ var ErrorMissingCertificate = errors.New("missing certificate")

+ var ErrorNoRouteToHost = errors.New("no route to host")

+ var ErrorNoSrpcEndpoint = errors.New("no SRPC endpoint")

+ func CheckTlsRequired() bool

+ func GetEarliestClientCertExpiration() time.Time

+ func LoadCertificates(directory string) ([]tls.Certificate, error)

+ func RegisterClientTlsConfig(config *tls.Config)

+ func RegisterFullAuthCA(certPool *x509.CertPool)

+ func RegisterName(name string, rcvr interface{}) error

+ func RegisterNameWithOptions(name string, rcvr interface{}, options ReceiverOptions) error

+ func RegisterServerTlsConfig(config *tls.Config, requireTls bool)

+ func SetDefaultGrantMethod(grantMethod func(serviceMethod string, authInfo *AuthInformation) bool)

+ type AuthInformation struct

+ GroupList map[string]struct{}

+ HaveMethodAccess bool

+ Username string

+ type Client struct

+ func DialHTTP(network, address string, timeout time.Duration) (*Client, error)

+ func DialHTTPWithDialer(network, address string, dialer Dialer) (*Client, error)

+ func DialTlsHTTP(network, address string, tlsConfig *tls.Config, timeout time.Duration) (*Client, error)

+ func DialTlsHTTPWithDialer(network, address string, tlsConfig *tls.Config, dialer Dialer) (*Client, error)

+ func (client *Client) Call(serviceMethod string) (*Conn, error)

+ func (client *Client) Close() error

+ func (client *Client) IsEncrypted() bool

+ func (client *Client) Ping() error

+ func (client *Client) Put()

+ func (client *Client) RequestReply(serviceMethod string, request interface{}, reply interface{}) error

+ func (client *Client) SetKeepAlive(keepalive bool) error

+ func (client *Client) SetKeepAlivePeriod(d time.Duration) error

+ type ClientResource struct

+ func NewClientResource(network, address string) *ClientResource

+ func (cr *ClientResource) GetHTTP(cancelChannel <-chan struct{}, timeout time.Duration) (*Client, error)

+ func (cr *ClientResource) GetHTTPWithDialer(cancelChannel <-chan struct{}, dialer Dialer) (*Client, error)

+ func (cr *ClientResource) GetTlsHTTP(tlsConfig *tls.Config, cancelChannel <-chan struct{}, timeout time.Duration) (*Client, error)

+ func (cr *ClientResource) GetTlsHTTPWithDialer(tlsConfig *tls.Config, cancelChannel <-chan struct{}, dialer Dialer) (*Client, error)

+ func (cr *ClientResource) ScheduleClose()

+ type Conn struct

+ func (conn *Conn) Close() error

+ func (conn *Conn) GetAuthInformation() *AuthInformation

+ func (conn *Conn) GetCloseNotifier() <-chan error

+ func (conn *Conn) IsEncrypted() bool

+ func (conn *Conn) RemoteAddr() string

+ func (conn *Conn) RequestReply(request interface{}, reply interface{}) error

+ func (conn *Conn) Username() string

+ type Decoder interface

+ Decode func(e interface{}) error

+ type Dialer interface

+ Dial func(network, address string) (net.Conn, error)

+ type Encoder interface

+ Encode func(e interface{}) error

+ type MethodBlocker interface

+ BlockMethod func(methodName string, authInfo *AuthInformation) (func(), error)

+ type MethodGranter interface

+ GrantMethod func(serviceMethod string, authInfo *AuthInformation) bool

+ type ReceiverOptions struct

+ PublicMethods []string