proto

Documentation

Index

• Variables
• func RegisterAuthServiceServer(s *grpc.Server, srv AuthServiceServer)
• type AuthServiceClient
  • func NewAuthServiceClient(cc *grpc.ClientConn) 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) GetResource() isEvent_Resource
  • func (m *Event) GetResourceHeader() *services.ResourceHeader
  • 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
  • func (m *Event_CertAuthority) MarshalTo(dAtA []byte) (int, error)
  • func (m *Event_CertAuthority) Size() (n int)
• type Event_ResourceHeader
  • func (m *Event_ResourceHeader) MarshalTo(dAtA []byte) (int, error)
  • func (m *Event_ResourceHeader) Size() (n int)
• type Operation
  • func (Operation) EnumDescriptor() ([]byte, []int)
  • func (x Operation) String() string
• 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

Variables

var (
	ErrInvalidLengthAuth = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAuth   = fmt.Errorf("proto: integer overflow")
)

var Operation_name = map[int32]string{
	0: "PUT",
	1: "DELETE",
}

var Operation_value = map[string]int32{
	"PUT":    0,
	"DELETE": 1,
}

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

func (m *Event) GetResource() isEvent_Resource

func (*Event) GetResourceHeader

func (m *Event) GetResourceHeader() *services.ResourceHeader

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_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 Operation

type Operation int32

Operation identifies type of operation

const (
	// PUT identifies created or updated object
	Operation_PUT Operation = 0
	// DELETE identifies deleted object
	Operation_DELETE Operation = 1
)

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                []string `protobuf:"bytes,1,rep,name=Kinds" json:"cert_authority,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Watch

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