hubv1grpc

package
v1.3.0-20231026123415-... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: unknown License: Apache-2.0 Imports: 5 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	ConfigService_GetGuardConfig_FullMethodName    = "/stanza.hub.v1.ConfigService/GetGuardConfig"
	ConfigService_GetBrowserContext_FullMethodName = "/stanza.hub.v1.ConfigService/GetBrowserContext"
	ConfigService_GetServiceConfig_FullMethodName  = "/stanza.hub.v1.ConfigService/GetServiceConfig"
)
View Source 
const (
	QuotaService_GetToken_FullMethodName              = "/stanza.hub.v1.QuotaService/GetToken"
	QuotaService_GetTokenLease_FullMethodName         = "/stanza.hub.v1.QuotaService/GetTokenLease"
	QuotaService_SetTokenLeaseConsumed_FullMethodName = "/stanza.hub.v1.QuotaService/SetTokenLeaseConsumed"
	QuotaService_ValidateToken_FullMethodName         = "/stanza.hub.v1.QuotaService/ValidateToken"
)
View Source 
const (
	AuthService_GetBearerToken_FullMethodName = "/stanza.hub.v1.AuthService/GetBearerToken"
)
View Source 
const (
	HealthService_QueryGuardHealth_FullMethodName = "/stanza.hub.v1.HealthService/QueryGuardHealth"
)
View Source 
const (
	StreamBalancerService_UpdateStreams_FullMethodName = "/stanza.hub.v1.StreamBalancerService/UpdateStreams"
)
View Source 
const (
	UsageService_GetUsage_FullMethodName = "/stanza.hub.v1.UsageService/GetUsage"
)

Variables

View Source 
var AuthService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stanza.hub.v1.AuthService",
	HandlerType: (*AuthServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetBearerToken",
			Handler:    _AuthService_GetBearerToken_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "stanza/hub/v1/auth.proto",
}

AuthService_ServiceDesc is the grpc.ServiceDesc for AuthService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stanza.hub.v1.ConfigService",
	HandlerType: (*ConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetGuardConfig",
			Handler:    _ConfigService_GetGuardConfig_Handler,
		},
		{
			MethodName: "GetBrowserContext",
			Handler:    _ConfigService_GetBrowserContext_Handler,
		},
		{
			MethodName: "GetServiceConfig",
			Handler:    _ConfigService_GetServiceConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "stanza/hub/v1/config.proto",
}

ConfigService_ServiceDesc is the grpc.ServiceDesc for ConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var HealthService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stanza.hub.v1.HealthService",
	HandlerType: (*HealthServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryGuardHealth",
			Handler:    _HealthService_QueryGuardHealth_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "stanza/hub/v1/health.proto",
}

HealthService_ServiceDesc is the grpc.ServiceDesc for HealthService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var QuotaService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stanza.hub.v1.QuotaService",
	HandlerType: (*QuotaServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetToken",
			Handler:    _QuotaService_GetToken_Handler,
		},
		{
			MethodName: "GetTokenLease",
			Handler:    _QuotaService_GetTokenLease_Handler,
		},
		{
			MethodName: "SetTokenLeaseConsumed",
			Handler:    _QuotaService_SetTokenLeaseConsumed_Handler,
		},
		{
			MethodName: "ValidateToken",
			Handler:    _QuotaService_ValidateToken_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "stanza/hub/v1/quota.proto",
}

QuotaService_ServiceDesc is the grpc.ServiceDesc for QuotaService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var StreamBalancerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stanza.hub.v1.StreamBalancerService",
	HandlerType: (*StreamBalancerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateStreams",
			Handler:    _StreamBalancerService_UpdateStreams_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "stanza/hub/v1/stream.proto",
}

StreamBalancerService_ServiceDesc is the grpc.ServiceDesc for StreamBalancerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var UsageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stanza.hub.v1.UsageService",
	HandlerType: (*UsageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetUsage",
			Handler:    _UsageService_GetUsage_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "stanza/hub/v1/usage.proto",
}

UsageService_ServiceDesc is the grpc.ServiceDesc for UsageService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAuthServiceServer 

func RegisterAuthServiceServer(s grpc.ServiceRegistrar, srv AuthServiceServer)

func RegisterConfigServiceServer 

func RegisterConfigServiceServer(s grpc.ServiceRegistrar, srv ConfigServiceServer)

func RegisterHealthServiceServer 

func RegisterHealthServiceServer(s grpc.ServiceRegistrar, srv HealthServiceServer)

func RegisterQuotaServiceServer 

func RegisterQuotaServiceServer(s grpc.ServiceRegistrar, srv QuotaServiceServer)

func RegisterStreamBalancerServiceServer 

func RegisterStreamBalancerServiceServer(s grpc.ServiceRegistrar, srv StreamBalancerServiceServer)

func RegisterUsageServiceServer 

func RegisterUsageServiceServer(s grpc.ServiceRegistrar, srv UsageServiceServer)

Types

type AuthServiceClient 

type AuthServiceClient interface {
	GetBearerToken(ctx context.Context, in *v1.GetBearerTokenRequest, opts ...grpc.CallOption) (*v1.GetBearerTokenResponse, error)
}

AuthServiceClient is the client API for AuthService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAuthServiceClient 

func NewAuthServiceClient(cc grpc.ClientConnInterface) AuthServiceClient

type AuthServiceServer 

type AuthServiceServer interface {
	GetBearerToken(context.Context, *v1.GetBearerTokenRequest) (*v1.GetBearerTokenResponse, error)
}

AuthServiceServer is the server API for AuthService service. All implementations should embed UnimplementedAuthServiceServer for forward compatibility

type ConfigServiceClient 

type ConfigServiceClient interface {
	GetGuardConfig(ctx context.Context, in *v1.GetGuardConfigRequest, opts ...grpc.CallOption) (*v1.GetGuardConfigResponse, error)
	GetBrowserContext(ctx context.Context, in *v1.GetBrowserContextRequest, opts ...grpc.CallOption) (*v1.GetBrowserContextResponse, error)
	GetServiceConfig(ctx context.Context, in *v1.GetServiceConfigRequest, opts ...grpc.CallOption) (*v1.GetServiceConfigResponse, error)
}

ConfigServiceClient is the client API for ConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewConfigServiceClient 

func NewConfigServiceClient(cc grpc.ClientConnInterface) ConfigServiceClient

type ConfigServiceServer 

type ConfigServiceServer interface {
	GetGuardConfig(context.Context, *v1.GetGuardConfigRequest) (*v1.GetGuardConfigResponse, error)
	GetBrowserContext(context.Context, *v1.GetBrowserContextRequest) (*v1.GetBrowserContextResponse, error)
	GetServiceConfig(context.Context, *v1.GetServiceConfigRequest) (*v1.GetServiceConfigResponse, error)
}

ConfigServiceServer is the server API for ConfigService service. All implementations should embed UnimplementedConfigServiceServer for forward compatibility

type HealthServiceClient 

type HealthServiceClient interface {
	QueryGuardHealth(ctx context.Context, in *v1.QueryGuardHealthRequest, opts ...grpc.CallOption) (*v1.QueryGuardHealthResponse, error)
}

HealthServiceClient is the client API for HealthService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewHealthServiceClient 

func NewHealthServiceClient(cc grpc.ClientConnInterface) HealthServiceClient

type HealthServiceServer 

type HealthServiceServer interface {
	QueryGuardHealth(context.Context, *v1.QueryGuardHealthRequest) (*v1.QueryGuardHealthResponse, error)
}

HealthServiceServer is the server API for HealthService service. All implementations should embed UnimplementedHealthServiceServer for forward compatibility

type QuotaServiceClient 

type QuotaServiceClient interface {
	GetToken(ctx context.Context, in *v1.GetTokenRequest, opts ...grpc.CallOption) (*v1.GetTokenResponse, error)
	GetTokenLease(ctx context.Context, in *v1.GetTokenLeaseRequest, opts ...grpc.CallOption) (*v1.GetTokenLeaseResponse, error)
	SetTokenLeaseConsumed(ctx context.Context, in *v1.SetTokenLeaseConsumedRequest, opts ...grpc.CallOption) (*v1.SetTokenLeaseConsumedResponse, error)
	// Used by ingress Guards to validate Hub-generated tokens.
	ValidateToken(ctx context.Context, in *v1.ValidateTokenRequest, opts ...grpc.CallOption) (*v1.ValidateTokenResponse, error)
}

QuotaServiceClient is the client API for QuotaService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQuotaServiceClient 

func NewQuotaServiceClient(cc grpc.ClientConnInterface) QuotaServiceClient

type QuotaServiceServer 

type QuotaServiceServer interface {
	GetToken(context.Context, *v1.GetTokenRequest) (*v1.GetTokenResponse, error)
	GetTokenLease(context.Context, *v1.GetTokenLeaseRequest) (*v1.GetTokenLeaseResponse, error)
	SetTokenLeaseConsumed(context.Context, *v1.SetTokenLeaseConsumedRequest) (*v1.SetTokenLeaseConsumedResponse, error)
	// Used by ingress Guards to validate Hub-generated tokens.
	ValidateToken(context.Context, *v1.ValidateTokenRequest) (*v1.ValidateTokenResponse, error)
}

QuotaServiceServer is the server API for QuotaService service. All implementations should embed UnimplementedQuotaServiceServer for forward compatibility

type StreamBalancerServiceClient 

type StreamBalancerServiceClient interface {
	UpdateStreams(ctx context.Context, in *v1.UpdateStreamsRequest, opts ...grpc.CallOption) (*v1.UpdateStreamsResponse, error)
}

StreamBalancerServiceClient is the client API for StreamBalancerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamBalancerServiceClient 

func NewStreamBalancerServiceClient(cc grpc.ClientConnInterface) StreamBalancerServiceClient

type StreamBalancerServiceServer 

type StreamBalancerServiceServer interface {
	UpdateStreams(context.Context, *v1.UpdateStreamsRequest) (*v1.UpdateStreamsResponse, error)
}

StreamBalancerServiceServer is the server API for StreamBalancerService service. All implementations should embed UnimplementedStreamBalancerServiceServer for forward compatibility

type UnimplementedAuthServiceServer 

type UnimplementedAuthServiceServer struct {
}

UnimplementedAuthServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAuthServiceServer) GetBearerToken 

func (UnimplementedAuthServiceServer) GetBearerToken(context.Context, *v1.GetBearerTokenRequest) (*v1.GetBearerTokenResponse, error)

type UnimplementedConfigServiceServer 

type UnimplementedConfigServiceServer struct {
}

UnimplementedConfigServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedConfigServiceServer) GetBrowserContext 

func (UnimplementedConfigServiceServer) GetBrowserContext(context.Context, *v1.GetBrowserContextRequest) (*v1.GetBrowserContextResponse, error)

func (UnimplementedConfigServiceServer) GetGuardConfig 

func (UnimplementedConfigServiceServer) GetGuardConfig(context.Context, *v1.GetGuardConfigRequest) (*v1.GetGuardConfigResponse, error)

func (UnimplementedConfigServiceServer) GetServiceConfig 

func (UnimplementedConfigServiceServer) GetServiceConfig(context.Context, *v1.GetServiceConfigRequest) (*v1.GetServiceConfigResponse, error)

type UnimplementedHealthServiceServer 

type UnimplementedHealthServiceServer struct {
}

UnimplementedHealthServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedHealthServiceServer) QueryGuardHealth 

func (UnimplementedHealthServiceServer) QueryGuardHealth(context.Context, *v1.QueryGuardHealthRequest) (*v1.QueryGuardHealthResponse, error)

type UnimplementedQuotaServiceServer 

type UnimplementedQuotaServiceServer struct {
}

UnimplementedQuotaServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedQuotaServiceServer) GetToken 

func (UnimplementedQuotaServiceServer) GetToken(context.Context, *v1.GetTokenRequest) (*v1.GetTokenResponse, error)

func (UnimplementedQuotaServiceServer) GetTokenLease 

func (UnimplementedQuotaServiceServer) GetTokenLease(context.Context, *v1.GetTokenLeaseRequest) (*v1.GetTokenLeaseResponse, error)

func (UnimplementedQuotaServiceServer) SetTokenLeaseConsumed 

func (UnimplementedQuotaServiceServer) SetTokenLeaseConsumed(context.Context, *v1.SetTokenLeaseConsumedRequest) (*v1.SetTokenLeaseConsumedResponse, error)

func (UnimplementedQuotaServiceServer) ValidateToken 

func (UnimplementedQuotaServiceServer) ValidateToken(context.Context, *v1.ValidateTokenRequest) (*v1.ValidateTokenResponse, error)

type UnimplementedStreamBalancerServiceServer 

type UnimplementedStreamBalancerServiceServer struct {
}

UnimplementedStreamBalancerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamBalancerServiceServer) UpdateStreams 

func (UnimplementedStreamBalancerServiceServer) UpdateStreams(context.Context, *v1.UpdateStreamsRequest) (*v1.UpdateStreamsResponse, error)

type UnimplementedUsageServiceServer 

type UnimplementedUsageServiceServer struct {
}

UnimplementedUsageServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedUsageServiceServer) GetUsage 

func (UnimplementedUsageServiceServer) GetUsage(context.Context, *v1.GetUsageRequest) (*v1.GetUsageResponse, error)

type UnsafeAuthServiceServer 

type UnsafeAuthServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAuthServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthServiceServer will result in compilation errors.

type UnsafeConfigServiceServer 

type UnsafeConfigServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConfigServiceServer will result in compilation errors.

type UnsafeHealthServiceServer 

type UnsafeHealthServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeHealthServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthServiceServer will result in compilation errors.

type UnsafeQuotaServiceServer 

type UnsafeQuotaServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeQuotaServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QuotaServiceServer will result in compilation errors.

type UnsafeStreamBalancerServiceServer 

type UnsafeStreamBalancerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamBalancerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamBalancerServiceServer will result in compilation errors.

type UnsafeUsageServiceServer 

type UnsafeUsageServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeUsageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UsageServiceServer will result in compilation errors.

type UsageServiceClient 

type UsageServiceClient interface {
	GetUsage(ctx context.Context, in *v1.GetUsageRequest, opts ...grpc.CallOption) (*v1.GetUsageResponse, error)
}

UsageServiceClient is the client API for UsageService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewUsageServiceClient 

func NewUsageServiceClient(cc grpc.ClientConnInterface) UsageServiceClient

type UsageServiceServer 

type UsageServiceServer interface {
	GetUsage(context.Context, *v1.GetUsageRequest) (*v1.GetUsageResponse, error)
}

UsageServiceServer is the server API for UsageService service. All implementations should embed UnimplementedUsageServiceServer for forward compatibility

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.