proto

package
v4.0.12+incompatible Latest Latest
Warning

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

Go to latest
Published: Dec 10, 2019 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL