Documentation ¶
Index ¶
- Constants
- Variables
- func TimeoutClientInterceptor(timeout time.Duration) ...
- func TimeoutServerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
- type CredentialProvider
- type FileProvider
- type GrpcBuilder
- func (it *GrpcBuilder) Build() (*grpc.ClientConn, error)
- func (it *GrpcBuilder) Insecure() *GrpcBuilder
- func (it *GrpcBuilder) TLSFromFile(caCertPath string, certPath string, keyPath string) *GrpcBuilder
- func (it *GrpcBuilder) TLSFromRaw(caCert []byte, cert []byte, key []byte) *GrpcBuilder
- func (it *GrpcBuilder) WithDefaultTimeout() *GrpcBuilder
- func (it *GrpcBuilder) WithNamespacedName(id types.NamespacedName) *GrpcBuilder
- func (it *GrpcBuilder) WithTimeout(timeout time.Duration) *GrpcBuilder
- type InsecureProvider
- type RawProvider
- type TLSFile
- type TLSRaw
Constants ¶
View Source
const ChaosDaemonServerName = "chaos-daemon.chaos-mesh.org"
View Source
const DefaultRPCTimeout = 60 * time.Second
DefaultRPCTimeout specifies default timeout of RPC between controller and chaos-operator
Variables ¶
View Source
var RPCTimeout = DefaultRPCTimeout
RPCTimeout specifies timeout of RPC between controller and chaos-operator
Functions ¶
func TimeoutClientInterceptor ¶
func TimeoutClientInterceptor(timeout time.Duration) func(context.Context, string, interface{}, interface{}, *grpc.ClientConn, grpc.UnaryInvoker, ...grpc.CallOption) error
TimeoutClientInterceptor wraps the RPC with a timeout.
func TimeoutServerInterceptor ¶
func TimeoutServerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)
TimeoutServerInterceptor ensures the context is intact before handling over the request to application.
Types ¶
type CredentialProvider ¶
type CredentialProvider interface {
// contains filtered or unexported methods
}
type FileProvider ¶
type FileProvider struct {
// contains filtered or unexported fields
}
type GrpcBuilder ¶
type GrpcBuilder struct {
// contains filtered or unexported fields
}
func Builder ¶
func Builder(address string, port int) *GrpcBuilder
func (*GrpcBuilder) Build ¶
func (it *GrpcBuilder) Build() (*grpc.ClientConn, error)
func (*GrpcBuilder) Insecure ¶
func (it *GrpcBuilder) Insecure() *GrpcBuilder
func (*GrpcBuilder) TLSFromFile ¶
func (it *GrpcBuilder) TLSFromFile(caCertPath string, certPath string, keyPath string) *GrpcBuilder
func (*GrpcBuilder) TLSFromRaw ¶
func (it *GrpcBuilder) TLSFromRaw(caCert []byte, cert []byte, key []byte) *GrpcBuilder
func (*GrpcBuilder) WithDefaultTimeout ¶
func (it *GrpcBuilder) WithDefaultTimeout() *GrpcBuilder
func (*GrpcBuilder) WithNamespacedName ¶
func (it *GrpcBuilder) WithNamespacedName(id types.NamespacedName) *GrpcBuilder
func (*GrpcBuilder) WithTimeout ¶
func (it *GrpcBuilder) WithTimeout(timeout time.Duration) *GrpcBuilder
type InsecureProvider ¶
type InsecureProvider struct { }
type RawProvider ¶
type RawProvider struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.