Documentation
¶
Index ¶
- Variables
- func RegisterAuthServiceServer(s *grpc.Server, srv AuthServiceServer)
- type AuthServiceClient
- type AuthServiceServer
- type AuthService_SendKeepAlivesClient
- type AuthService_SendKeepAlivesServer
- type AuthService_WatchEventsClient
- type AuthService_WatchEventsServer
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetCertAuthority() *services.CertAuthorityV2
- func (m *Event) GetClusterConfig() *services.ClusterConfigV3
- func (m *Event) GetClusterName() *services.ClusterNameV2
- func (m *Event) GetNamespace() *services.Namespace
- func (m *Event) GetProvisionToken() *services.ProvisionTokenV2
- func (m *Event) GetResource() isEvent_Resource
- func (m *Event) GetResourceHeader() *services.ResourceHeader
- func (m *Event) GetReverseTunnel() *services.ReverseTunnelV2
- func (m *Event) GetRole() *services.RoleV3
- func (m *Event) GetServer() *services.ServerV2
- func (m *Event) GetStaticTokens() *services.StaticTokensV2
- func (m *Event) GetTunnelConnection() *services.TunnelConnectionV2
- func (m *Event) GetUser() *services.UserV2
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (m *Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Event) XXX_Merge(src proto.Message)
- func (*Event) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type Event_CertAuthority
- type Event_ClusterConfig
- type Event_ClusterName
- type Event_Namespace
- type Event_ProvisionToken
- type Event_ResourceHeader
- type Event_ReverseTunnel
- type Event_Role
- type Event_Server
- type Event_StaticTokens
- type Event_TunnelConnection
- type Event_User
- type Operation
- type Watch
- func (*Watch) Descriptor() ([]byte, []int)
- func (m *Watch) Marshal() (dAtA []byte, err error)
- func (m *Watch) MarshalTo(dAtA []byte) (int, error)
- func (*Watch) ProtoMessage()
- func (m *Watch) Reset()
- func (m *Watch) Size() (n int)
- func (m *Watch) String() string
- func (m *Watch) Unmarshal(dAtA []byte) error
- func (m *Watch) XXX_DiscardUnknown()
- func (m *Watch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Watch) XXX_Merge(src proto.Message)
- func (m *Watch) XXX_Size() int
- func (m *Watch) XXX_Unmarshal(b []byte) error
- type WatchKind
- func (*WatchKind) Descriptor() ([]byte, []int)
- func (m *WatchKind) Marshal() (dAtA []byte, err error)
- func (m *WatchKind) MarshalTo(dAtA []byte) (int, error)
- func (*WatchKind) ProtoMessage()
- func (m *WatchKind) Reset()
- func (m *WatchKind) Size() (n int)
- func (m *WatchKind) String() string
- func (m *WatchKind) Unmarshal(dAtA []byte) error
- func (m *WatchKind) XXX_DiscardUnknown()
- func (m *WatchKind) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WatchKind) XXX_Merge(src proto.Message)
- func (m *WatchKind) XXX_Size() int
- func (m *WatchKind) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthAuth = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAuth = fmt.Errorf("proto: integer overflow") )
View Source
var Operation_name = map[int32]string{
0: "INIT",
1: "PUT",
2: "DELETE",
}
View Source
var Operation_value = map[string]int32{
"INIT": 0,
"PUT": 1,
"DELETE": 2,
}
Functions ¶
func RegisterAuthServiceServer ¶
func RegisterAuthServiceServer(s *grpc.Server, srv AuthServiceServer)
Types ¶
type AuthServiceClient ¶
type AuthServiceClient interface {
// SendKeepAlives allows node to send a stream of keep alive requests
SendKeepAlives(ctx context.Context, opts ...grpc.CallOption) (AuthService_SendKeepAlivesClient, error)
// WatchEvents returns a new stream of cluster events
WatchEvents(ctx context.Context, in *Watch, opts ...grpc.CallOption) (AuthService_WatchEventsClient, error)
// UpsertNode upserts node
UpsertNode(ctx context.Context, in *services.ServerV2, opts ...grpc.CallOption) (*services.KeepAlive, error)
}
func NewAuthServiceClient ¶
func NewAuthServiceClient(cc *grpc.ClientConn) AuthServiceClient
type AuthServiceServer ¶
type AuthServiceServer interface {
// SendKeepAlives allows node to send a stream of keep alive requests
SendKeepAlives(AuthService_SendKeepAlivesServer) error
// WatchEvents returns a new stream of cluster events
WatchEvents(*Watch, AuthService_WatchEventsServer) error
// UpsertNode upserts node
UpsertNode(context.Context, *services.ServerV2) (*services.KeepAlive, error)
}
type AuthService_WatchEventsClient ¶
type AuthService_WatchEventsClient interface {
Recv() (*Event, error)
grpc.ClientStream
}
type AuthService_WatchEventsServer ¶
type AuthService_WatchEventsServer interface {
Send(*Event) error
grpc.ServerStream
}
type Event ¶
type Event struct {
// Operation identifies operation
Type Operation `protobuf:"varint,1,opt,name=Type,proto3,enum=proto.Operation" json:"type,omitempty"`
// Resource contains the updated resource
//
// Types that are valid to be assigned to Resource:
// *Event_ResourceHeader
// *Event_CertAuthority
// *Event_StaticTokens
// *Event_ProvisionToken
// *Event_ClusterName
// *Event_ClusterConfig
// *Event_User
// *Event_Role
// *Event_Namespace
// *Event_Server
// *Event_ReverseTunnel
// *Event_TunnelConnection
Resource isEvent_Resource `protobuf_oneof:"Resource"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Event returns cluster event
func (*Event) Descriptor ¶
func (*Event) GetCertAuthority ¶
func (m *Event) GetCertAuthority() *services.CertAuthorityV2
func (*Event) GetClusterConfig ¶
func (m *Event) GetClusterConfig() *services.ClusterConfigV3
func (*Event) GetClusterName ¶
func (m *Event) GetClusterName() *services.ClusterNameV2
func (*Event) GetNamespace ¶
func (*Event) GetProvisionToken ¶
func (m *Event) GetProvisionToken() *services.ProvisionTokenV2
func (*Event) GetResource ¶
func (m *Event) GetResource() isEvent_Resource
func (*Event) GetResourceHeader ¶
func (m *Event) GetResourceHeader() *services.ResourceHeader
func (*Event) GetReverseTunnel ¶
func (m *Event) GetReverseTunnel() *services.ReverseTunnelV2
func (*Event) GetStaticTokens ¶
func (m *Event) GetStaticTokens() *services.StaticTokensV2
func (*Event) GetTunnelConnection ¶
func (m *Event) GetTunnelConnection() *services.TunnelConnectionV2
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_OneofFuncs ¶
func (*Event) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*Event) XXX_Unmarshal ¶
type Event_CertAuthority ¶
type Event_CertAuthority struct {
CertAuthority *services.CertAuthorityV2 `protobuf:"bytes,3,opt,name=CertAuthority,oneof"`
}
func (*Event_CertAuthority) MarshalTo ¶
func (m *Event_CertAuthority) MarshalTo(dAtA []byte) (int, error)
func (*Event_CertAuthority) Size ¶
func (m *Event_CertAuthority) Size() (n int)
type Event_ClusterConfig ¶
type Event_ClusterConfig struct {
ClusterConfig *services.ClusterConfigV3 `protobuf:"bytes,7,opt,name=ClusterConfig,oneof"`
}
func (*Event_ClusterConfig) MarshalTo ¶
func (m *Event_ClusterConfig) MarshalTo(dAtA []byte) (int, error)
func (*Event_ClusterConfig) Size ¶
func (m *Event_ClusterConfig) Size() (n int)
type Event_ClusterName ¶
type Event_ClusterName struct {
ClusterName *services.ClusterNameV2 `protobuf:"bytes,6,opt,name=ClusterName,oneof"`
}
func (*Event_ClusterName) MarshalTo ¶
func (m *Event_ClusterName) MarshalTo(dAtA []byte) (int, error)
func (*Event_ClusterName) Size ¶
func (m *Event_ClusterName) Size() (n int)
type Event_Namespace ¶
type Event_Namespace struct {
Namespace *services.Namespace `protobuf:"bytes,10,opt,name=Namespace,oneof"`
}
func (*Event_Namespace) Size ¶
func (m *Event_Namespace) Size() (n int)
type Event_ProvisionToken ¶
type Event_ProvisionToken struct {
ProvisionToken *services.ProvisionTokenV2 `protobuf:"bytes,5,opt,name=ProvisionToken,oneof"`
}
func (*Event_ProvisionToken) MarshalTo ¶
func (m *Event_ProvisionToken) MarshalTo(dAtA []byte) (int, error)
func (*Event_ProvisionToken) Size ¶
func (m *Event_ProvisionToken) Size() (n int)
type Event_ResourceHeader ¶
type Event_ResourceHeader struct {
ResourceHeader *services.ResourceHeader `protobuf:"bytes,2,opt,name=ResourceHeader,oneof"`
}
func (*Event_ResourceHeader) MarshalTo ¶
func (m *Event_ResourceHeader) MarshalTo(dAtA []byte) (int, error)
func (*Event_ResourceHeader) Size ¶
func (m *Event_ResourceHeader) Size() (n int)
type Event_ReverseTunnel ¶
type Event_ReverseTunnel struct {
ReverseTunnel *services.ReverseTunnelV2 `protobuf:"bytes,12,opt,name=ReverseTunnel,oneof"`
}
func (*Event_ReverseTunnel) MarshalTo ¶
func (m *Event_ReverseTunnel) MarshalTo(dAtA []byte) (int, error)
func (*Event_ReverseTunnel) Size ¶
func (m *Event_ReverseTunnel) Size() (n int)
type Event_Role ¶
func (*Event_Role) Size ¶
func (m *Event_Role) Size() (n int)
type Event_Server ¶
func (*Event_Server) Size ¶
func (m *Event_Server) Size() (n int)
type Event_StaticTokens ¶
type Event_StaticTokens struct {
StaticTokens *services.StaticTokensV2 `protobuf:"bytes,4,opt,name=StaticTokens,oneof"`
}
func (*Event_StaticTokens) MarshalTo ¶
func (m *Event_StaticTokens) MarshalTo(dAtA []byte) (int, error)
func (*Event_StaticTokens) Size ¶
func (m *Event_StaticTokens) Size() (n int)
type Event_TunnelConnection ¶
type Event_TunnelConnection struct {
TunnelConnection *services.TunnelConnectionV2 `protobuf:"bytes,13,opt,name=TunnelConnection,oneof"`
}
func (*Event_TunnelConnection) MarshalTo ¶
func (m *Event_TunnelConnection) MarshalTo(dAtA []byte) (int, error)
func (*Event_TunnelConnection) Size ¶
func (m *Event_TunnelConnection) Size() (n int)
type Event_User ¶
func (*Event_User) Size ¶
func (m *Event_User) Size() (n int)
type Operation ¶
type Operation int32
Operation identifies type of operation
func (Operation) EnumDescriptor ¶
type Watch ¶
type Watch struct {
// Kinds specifies object kinds to watch
Kinds []WatchKind `protobuf:"bytes,1,rep,name=Kinds" json:"kinds,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Watch specifies watch parameters
func (*Watch) Descriptor ¶
func (*Watch) ProtoMessage ¶
func (*Watch) ProtoMessage()
func (*Watch) XXX_DiscardUnknown ¶
func (m *Watch) XXX_DiscardUnknown()
func (*Watch) XXX_Marshal ¶
func (*Watch) XXX_Unmarshal ¶
type WatchKind ¶
type WatchKind struct {
// Kind is a resource kind to watch
Kind string `protobuf:"bytes,1,opt,name=Kind,proto3" json:"kind"`
// LoadSecrets specifies whether to load secrets
LoadSecrets bool `protobuf:"varint,2,opt,name=LoadSecrets,proto3" json:"load_secrets"`
// Name is an optional specific resource type to watch,
// if specified only the events with a specific resource
// name will be sent
Name string `protobuf:"bytes,3,opt,name=Name,proto3" json:"name"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
WatchKind specifies resource kind to watch
func (*WatchKind) Descriptor ¶
func (*WatchKind) ProtoMessage ¶
func (*WatchKind) ProtoMessage()
func (*WatchKind) XXX_DiscardUnknown ¶
func (m *WatchKind) XXX_DiscardUnknown()
func (*WatchKind) XXX_Marshal ¶
func (*WatchKind) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.