go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/proto/throttlerservice Index | Files

package throttlerservice

import "gopkg.in/src-d/go-vitess.v1/vt/proto/throttlerservice"

Index

Package Files

throttlerservice.pb.go

func RegisterThrottlerServer Uses

func RegisterThrottlerServer(s *grpc.Server, srv ThrottlerServer)

type ThrottlerClient Uses

type ThrottlerClient interface {
    // MaxRates returns the current max rate for each throttler of the process.
    MaxRates(ctx context.Context, in *throttlerdata.MaxRatesRequest, opts ...grpc.CallOption) (*throttlerdata.MaxRatesResponse, error)
    // SetMaxRate allows to change the current max rate for all throttlers
    // of the process.
    SetMaxRate(ctx context.Context, in *throttlerdata.SetMaxRateRequest, opts ...grpc.CallOption) (*throttlerdata.SetMaxRateResponse, error)
    // GetConfiguration returns the configuration of the MaxReplicationlag module
    // for the given throttler or all throttlers if "throttler_name" is empty.
    GetConfiguration(ctx context.Context, in *throttlerdata.GetConfigurationRequest, opts ...grpc.CallOption) (*throttlerdata.GetConfigurationResponse, error)
    // UpdateConfiguration (partially) updates the configuration of the
    // MaxReplicationlag module for the given throttler or all throttlers if
    // "throttler_name" is empty.
    // If "copy_zero_values" is true, fields with zero values will be copied
    // as well.
    UpdateConfiguration(ctx context.Context, in *throttlerdata.UpdateConfigurationRequest, opts ...grpc.CallOption) (*throttlerdata.UpdateConfigurationResponse, error)
    // ResetConfiguration resets the configuration of the MaxReplicationlag module
    // to the initial configuration for the given throttler or all throttlers if
    // "throttler_name" is empty.
    ResetConfiguration(ctx context.Context, in *throttlerdata.ResetConfigurationRequest, opts ...grpc.CallOption) (*throttlerdata.ResetConfigurationResponse, error)
}

ThrottlerClient is the client API for Throttler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewThrottlerClient Uses

func NewThrottlerClient(cc *grpc.ClientConn) ThrottlerClient

type ThrottlerServer Uses

type ThrottlerServer interface {
    // MaxRates returns the current max rate for each throttler of the process.
    MaxRates(context.Context, *throttlerdata.MaxRatesRequest) (*throttlerdata.MaxRatesResponse, error)
    // SetMaxRate allows to change the current max rate for all throttlers
    // of the process.
    SetMaxRate(context.Context, *throttlerdata.SetMaxRateRequest) (*throttlerdata.SetMaxRateResponse, error)
    // GetConfiguration returns the configuration of the MaxReplicationlag module
    // for the given throttler or all throttlers if "throttler_name" is empty.
    GetConfiguration(context.Context, *throttlerdata.GetConfigurationRequest) (*throttlerdata.GetConfigurationResponse, error)
    // UpdateConfiguration (partially) updates the configuration of the
    // MaxReplicationlag module for the given throttler or all throttlers if
    // "throttler_name" is empty.
    // If "copy_zero_values" is true, fields with zero values will be copied
    // as well.
    UpdateConfiguration(context.Context, *throttlerdata.UpdateConfigurationRequest) (*throttlerdata.UpdateConfigurationResponse, error)
    // ResetConfiguration resets the configuration of the MaxReplicationlag module
    // to the initial configuration for the given throttler or all throttlers if
    // "throttler_name" is empty.
    ResetConfiguration(context.Context, *throttlerdata.ResetConfigurationRequest) (*throttlerdata.ResetConfigurationResponse, error)
}

ThrottlerServer is the server API for Throttler service.

Package throttlerservice imports 6 packages (graph) and is imported by 4 packages. Updated 2019-06-13. Refresh now. Tools for package owners.