Function NewRPCConnection

api/connection.go:73–81

NewRPCConnection creates a new [RPCConnection] to the target using the specified function that creates a new client.

(target string, newClientFunc func(cc grpc.ClientConnInterface) T, opts ...grpc.DialOption)

// NewRPCConnection creates a new [RPCConnection] to the target using the specified function that creates a new client.
func NewRPCConnection[T any](target string, newClientFunc func(cc grpc.ClientConnInterface) T, opts ...grpc.DialOption) *RPCConnection[T] {
	conn := &RPCConnection[T]{
		Target: target,
		Opts:   opts,
	}
	conn.Client = newClientFunc(conn)

	return conn
}

// ForceReconnect drops the established gRPC client conn and forces a re-connect at the next client call.
func (conn *RPCConnection[T]) ForceReconnect() {