proto

package
v4.0.14+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

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_SendKeepAlivesClient 

type AuthService_SendKeepAlivesClient interface {
	Send(*services.KeepAlive) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type AuthService_SendKeepAlivesServer 

type AuthService_SendKeepAlivesServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*services.KeepAlive, error)
	grpc.ServerStream
}

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) Descriptor() ([]byte, []int)

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 (m *Event) GetNamespace() *services.Namespace

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) GetRole 

func (m *Event) GetRole() *services.RoleV3

func (*Event) GetServer 

func (m *Event) GetServer() *services.ServerV2

func (*Event) GetStaticTokens 

func (m *Event) GetStaticTokens() *services.StaticTokensV2

func (*Event) GetTunnelConnection 

func (m *Event) GetTunnelConnection() *services.TunnelConnectionV2

func (*Event) GetUser 

func (m *Event) GetUser() *services.UserV2

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (dst *Event) XXX_Merge(src proto.Message)

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_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *Event_Namespace) MarshalTo(dAtA []byte) (int, error)

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 

type Event_Role struct {
	Role *services.RoleV3 `protobuf:"bytes,9,opt,name=Role,oneof"`
}

func (*Event_Role) MarshalTo 

func (m *Event_Role) MarshalTo(dAtA []byte) (int, error)

func (*Event_Role) Size 

func (m *Event_Role) Size() (n int)

type Event_Server 

type Event_Server struct {
	Server *services.ServerV2 `protobuf:"bytes,11,opt,name=Server,oneof"`
}

func (*Event_Server) MarshalTo 

func (m *Event_Server) MarshalTo(dAtA []byte) (int, error)

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 

type Event_User struct {
	User *services.UserV2 `protobuf:"bytes,8,opt,name=User,oneof"`
}

func (*Event_User) MarshalTo 

func (m *Event_User) MarshalTo(dAtA []byte) (int, error)

func (*Event_User) Size 

func (m *Event_User) Size() (n int)

type Operation 

type Operation int32

Operation identifies type of operation 

const (
	// INIT is sent as a first sentinel event
	// on the watch channel
	Operation_INIT Operation = 0
	// PUT identifies created or updated object
	Operation_PUT Operation = 1
	// DELETE identifies deleted object
	Operation_DELETE Operation = 2
)

func (Operation) EnumDescriptor 

func (Operation) EnumDescriptor() ([]byte, []int)

func (Operation) String 

func (x Operation) String() string

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) Descriptor() ([]byte, []int)

func (*Watch) Marshal 

func (m *Watch) Marshal() (dAtA []byte, err error)

func (*Watch) MarshalTo 

func (m *Watch) MarshalTo(dAtA []byte) (int, error)

func (*Watch) ProtoMessage 

func (*Watch) ProtoMessage()

func (*Watch) Reset 

func (m *Watch) Reset()

func (*Watch) Size 

func (m *Watch) Size() (n int)

func (*Watch) String 

func (m *Watch) String() string

func (*Watch) Unmarshal 

func (m *Watch) Unmarshal(dAtA []byte) error

func (*Watch) XXX_DiscardUnknown 

func (m *Watch) XXX_DiscardUnknown()

func (*Watch) XXX_Marshal 

func (m *Watch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Watch) XXX_Merge 

func (dst *Watch) XXX_Merge(src proto.Message)

func (*Watch) XXX_Size 

func (m *Watch) XXX_Size() int

func (*Watch) XXX_Unmarshal 

func (m *Watch) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*WatchKind) Marshal 

func (m *WatchKind) Marshal() (dAtA []byte, err error)

func (*WatchKind) MarshalTo 

func (m *WatchKind) MarshalTo(dAtA []byte) (int, error)

func (*WatchKind) ProtoMessage 

func (*WatchKind) ProtoMessage()

func (*WatchKind) Reset 

func (m *WatchKind) Reset()

func (*WatchKind) Size 

func (m *WatchKind) Size() (n int)

func (*WatchKind) String 

func (m *WatchKind) String() string

func (*WatchKind) Unmarshal 

func (m *WatchKind) Unmarshal(dAtA []byte) error

func (*WatchKind) XXX_DiscardUnknown 

func (m *WatchKind) XXX_DiscardUnknown()

func (*WatchKind) XXX_Marshal 

func (m *WatchKind) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchKind) XXX_Merge 

func (dst *WatchKind) XXX_Merge(src proto.Message)

func (*WatchKind) XXX_Size 

func (m *WatchKind) XXX_Size() int

func (*WatchKind) XXX_Unmarshal 

func (m *WatchKind) XXX_Unmarshal(b []byte) error

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.