v1alpha1

package
v0.0.0-...-97dd610 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AuthorityService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.apache.dubbo.auth.v1alpha1.AuthorityService",
	HandlerType: (*AuthorityServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateIdentity",
			Handler:    _AuthorityService_CreateIdentity_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1alpha1/ca.proto",
}

AuthorityService_ServiceDesc is the grpc.ServiceDesc for AuthorityService 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 File_v1alpha1_ca_proto protoreflect.FileDescriptor
View Source 
var RuleService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.apache.dubbo.auth.v1alpha1.RuleService",
	HandlerType: (*RuleServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Observe",
			Handler:       _RuleService_Observe_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "v1alpha1/ca.proto",
}

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

Functions

func ExactEndpoint 

func ExactEndpoint(c context.Context, certStorage cert.Storage, options *config.Options, kubeClient k8s.Client) (*rule.Endpoint, error)

func RegisterAuthorityServiceServer 

func RegisterAuthorityServiceServer(s grpc.ServiceRegistrar, srv AuthorityServiceServer)

func RegisterRuleServiceServer 

func RegisterRuleServiceServer(s grpc.ServiceRegistrar, srv RuleServiceServer)

Types

type AuthorityServiceClient 

type AuthorityServiceClient interface {
	CreateIdentity(ctx context.Context, in *IdentityRequest, opts ...grpc.CallOption) (*IdentityResponse, error)
}

AuthorityServiceClient is the client API for AuthorityService 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 NewAuthorityServiceClient 

func NewAuthorityServiceClient(cc grpc.ClientConnInterface) AuthorityServiceClient

type AuthorityServiceImpl 

type AuthorityServiceImpl struct {
	UnimplementedAuthorityServiceServer
	Options     *config.Options
	CertStorage cert.Storage
	KubeClient  k8s.Client
}

func (*AuthorityServiceImpl) CreateIdentity 

func (s *AuthorityServiceImpl) CreateIdentity(
	c context.Context,
	req *IdentityRequest,
) (*IdentityResponse, error)

type AuthorityServiceServer 

type AuthorityServiceServer interface {
	CreateIdentity(context.Context, *IdentityRequest) (*IdentityResponse, error)
	// contains filtered or unexported methods
}

AuthorityServiceServer is the server API for AuthorityService service. All implementations must embed UnimplementedAuthorityServiceServer for forward compatibility

type GrpcEndpointConnection 

type GrpcEndpointConnection struct {
	connection.EndpointConnection
	// contains filtered or unexported fields
}

func (*GrpcEndpointConnection) Disconnect 

func (c *GrpcEndpointConnection) Disconnect()

func (*GrpcEndpointConnection) Recv 

func (c *GrpcEndpointConnection) Recv() (*connection.ObserveRequest, error)

func (*GrpcEndpointConnection) Send 

func (c *GrpcEndpointConnection) Send(r *connection.ObserveResponse) error

type IdentityRequest 

type IdentityRequest struct {
	Csr      string           `protobuf:"bytes,1,opt,name=csr,proto3" json:"csr,omitempty"`
	Type     string           `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Metadata *structpb.Struct `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*IdentityRequest) Descriptor deprecated 

func (*IdentityRequest) Descriptor() ([]byte, []int)

Deprecated: Use IdentityRequest.ProtoReflect.Descriptor instead.

func (*IdentityRequest) GetCsr 

func (x *IdentityRequest) GetCsr() string

func (*IdentityRequest) GetMetadata 

func (x *IdentityRequest) GetMetadata() *structpb.Struct

func (*IdentityRequest) GetType 

func (x *IdentityRequest) GetType() string

func (*IdentityRequest) ProtoMessage 

func (*IdentityRequest) ProtoMessage()

func (*IdentityRequest) ProtoReflect 

func (x *IdentityRequest) ProtoReflect() protoreflect.Message

func (*IdentityRequest) Reset 

func (x *IdentityRequest) Reset()

func (*IdentityRequest) String 

func (x *IdentityRequest) String() string

type IdentityResponse 

type IdentityResponse struct {
	Success                bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	CertPem                string   `protobuf:"bytes,2,opt,name=cert_pem,json=certPem,proto3" json:"cert_pem,omitempty"`
	TrustCerts             []string `protobuf:"bytes,3,rep,name=trust_certs,json=trustCerts,proto3" json:"trust_certs,omitempty"`
	Token                  string   `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	TrustedTokenPublicKeys []string `` /* 131-byte string literal not displayed */
	RefreshTime            int64    `protobuf:"varint,6,opt,name=refresh_time,json=refreshTime,proto3" json:"refresh_time,omitempty"`
	ExpireTime             int64    `protobuf:"varint,7,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	Message                string   `protobuf:"bytes,8,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*IdentityResponse) Descriptor deprecated 

func (*IdentityResponse) Descriptor() ([]byte, []int)

Deprecated: Use IdentityResponse.ProtoReflect.Descriptor instead.

func (*IdentityResponse) GetCertPem 

func (x *IdentityResponse) GetCertPem() string

func (*IdentityResponse) GetExpireTime 

func (x *IdentityResponse) GetExpireTime() int64

func (*IdentityResponse) GetMessage 

func (x *IdentityResponse) GetMessage() string

func (*IdentityResponse) GetRefreshTime 

func (x *IdentityResponse) GetRefreshTime() int64

func (*IdentityResponse) GetSuccess 

func (x *IdentityResponse) GetSuccess() bool

func (*IdentityResponse) GetToken 

func (x *IdentityResponse) GetToken() string

func (*IdentityResponse) GetTrustCerts 

func (x *IdentityResponse) GetTrustCerts() []string

func (*IdentityResponse) GetTrustedTokenPublicKeys 

func (x *IdentityResponse) GetTrustedTokenPublicKeys() []string

func (*IdentityResponse) ProtoMessage 

func (*IdentityResponse) ProtoMessage()

func (*IdentityResponse) ProtoReflect 

func (x *IdentityResponse) ProtoReflect() protoreflect.Message

func (*IdentityResponse) Reset 

func (x *IdentityResponse) Reset()

func (*IdentityResponse) String 

func (x *IdentityResponse) String() string

type ObserveRequest 

type ObserveRequest struct {
	Nonce string `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Type  string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ObserveRequest) Descriptor deprecated 

func (*ObserveRequest) Descriptor() ([]byte, []int)

Deprecated: Use ObserveRequest.ProtoReflect.Descriptor instead.

func (*ObserveRequest) GetNonce 

func (x *ObserveRequest) GetNonce() string

func (*ObserveRequest) GetType 

func (x *ObserveRequest) GetType() string

func (*ObserveRequest) ProtoMessage 

func (*ObserveRequest) ProtoMessage()

func (*ObserveRequest) ProtoReflect 

func (x *ObserveRequest) ProtoReflect() protoreflect.Message

func (*ObserveRequest) Reset 

func (x *ObserveRequest) Reset()

func (*ObserveRequest) String 

func (x *ObserveRequest) String() string

type ObserveResponse 

type ObserveResponse struct {
	Nonce    string `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Type     string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Revision int64  `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	Data     string `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ObserveResponse) Descriptor deprecated 

func (*ObserveResponse) Descriptor() ([]byte, []int)

Deprecated: Use ObserveResponse.ProtoReflect.Descriptor instead.

func (*ObserveResponse) GetData 

func (x *ObserveResponse) GetData() string

func (*ObserveResponse) GetNonce 

func (x *ObserveResponse) GetNonce() string

func (*ObserveResponse) GetRevision 

func (x *ObserveResponse) GetRevision() int64

func (*ObserveResponse) GetType 

func (x *ObserveResponse) GetType() string

func (*ObserveResponse) ProtoMessage 

func (*ObserveResponse) ProtoMessage()

func (*ObserveResponse) ProtoReflect 

func (x *ObserveResponse) ProtoReflect() protoreflect.Message

func (*ObserveResponse) Reset 

func (x *ObserveResponse) Reset()

func (*ObserveResponse) String 

func (x *ObserveResponse) String() string

type RuleServiceClient 

type RuleServiceClient interface {
	Observe(ctx context.Context, opts ...grpc.CallOption) (RuleService_ObserveClient, error)
}

RuleServiceClient is the client API for RuleService 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 NewRuleServiceClient 

func NewRuleServiceClient(cc grpc.ClientConnInterface) RuleServiceClient

type RuleServiceImpl 

type RuleServiceImpl struct {
	UnimplementedRuleServiceServer

	Options     *config.Options
	CertStorage cert.Storage
	KubeClient  k8s.Client
	Storage     *connection.Storage
}

func (*RuleServiceImpl) Observe 

func (s *RuleServiceImpl) Observe(stream RuleService_ObserveServer) error

type RuleServiceServer 

type RuleServiceServer interface {
	Observe(RuleService_ObserveServer) error
	// contains filtered or unexported methods
}

RuleServiceServer is the server API for RuleService service. All implementations must embed UnimplementedRuleServiceServer for forward compatibility

type RuleService_ObserveClient 

type RuleService_ObserveClient interface {
	Send(*ObserveRequest) error
	Recv() (*ObserveResponse, error)
	grpc.ClientStream
}

type RuleService_ObserveServer 

type RuleService_ObserveServer interface {
	Send(*ObserveResponse) error
	Recv() (*ObserveRequest, error)
	grpc.ServerStream
}

type UnimplementedAuthorityServiceServer 

type UnimplementedAuthorityServiceServer struct {
}

UnimplementedAuthorityServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAuthorityServiceServer) CreateIdentity 

func (UnimplementedAuthorityServiceServer) CreateIdentity(context.Context, *IdentityRequest) (*IdentityResponse, error)

type UnimplementedRuleServiceServer 

type UnimplementedRuleServiceServer struct {
}

UnimplementedRuleServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRuleServiceServer) Observe 

func (UnimplementedRuleServiceServer) Observe(RuleService_ObserveServer) error

type UnsafeAuthorityServiceServer 

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

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

type UnsafeRuleServiceServer 

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

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

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.