v1alpha1

package
v0.0.0-...-caac553 Latest Latest
Warning

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

 Go to latest Published: Aug 12, 2021 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Command_Operation_name = map[int32]string{
		0: "UPSERT",
		1: "DELETE",
		2: "LINK",
		3: "UNLINK",
	}
	Command_Operation_value = map[string]int32{
		"UPSERT": 0,
		"DELETE": 1,
		"LINK":   2,
		"UNLINK": 3,
	}
)

Enum value maps for Command_Operation.

View Source 
var File_command_proto protoreflect.FileDescriptor
View Source 
var File_core_proto protoreflect.FileDescriptor
View Source 
var File_kubelt_proto protoreflect.FileDescriptor
View Source 
var File_user_proto protoreflect.FileDescriptor
View Source 
var Kubelt_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kubelt.Kubelt",
	HandlerType: (*KubeltServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HealthCheck",
			Handler:    _Kubelt_HealthCheck_Handler,
		},
		{
			MethodName: "RegisterUser",
			Handler:    _Kubelt_RegisterUser_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Kubelt_Get_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _Kubelt_Query_Handler,
		},
		{
			MethodName: "Apply",
			Handler:    _Kubelt_Apply_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kubelt.proto",
}

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

Functions

func RegisterKubeltServer 

func RegisterKubeltServer(s grpc.ServiceRegistrar, srv KubeltServer)

Types

type Annotation 

type Annotation struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Annotation) Descriptor deprecated 

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

Deprecated: Use Annotation.ProtoReflect.Descriptor instead.

func (*Annotation) GetKey 

func (x *Annotation) GetKey() string

func (*Annotation) GetValue 

func (x *Annotation) GetValue() string

func (*Annotation) ProtoMessage 

func (*Annotation) ProtoMessage()

func (*Annotation) ProtoReflect 

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

func (*Annotation) Reset 

func (x *Annotation) Reset()

func (*Annotation) String 

func (x *Annotation) String() string

type ApplyRequest 

type ApplyRequest struct {
	Commands *Commands `protobuf:"bytes,1,opt,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

Apply

func (*ApplyRequest) Descriptor deprecated 

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

Deprecated: Use ApplyRequest.ProtoReflect.Descriptor instead.

func (*ApplyRequest) GetCommands 

func (x *ApplyRequest) GetCommands() *Commands

func (*ApplyRequest) ProtoMessage 

func (*ApplyRequest) ProtoMessage()

func (*ApplyRequest) ProtoReflect 

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

func (*ApplyRequest) Reset 

func (x *ApplyRequest) Reset()

func (*ApplyRequest) String 

func (x *ApplyRequest) String() string

type ApplyResponse 

type ApplyResponse struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Error *Error  `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyResponse) Descriptor deprecated 

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

Deprecated: Use ApplyResponse.ProtoReflect.Descriptor instead.

func (*ApplyResponse) GetError 

func (x *ApplyResponse) GetError() *Error

func (*ApplyResponse) GetNodes 

func (x *ApplyResponse) GetNodes() []*Node

func (*ApplyResponse) ProtoMessage 

func (*ApplyResponse) ProtoMessage()

func (*ApplyResponse) ProtoReflect 

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

func (*ApplyResponse) Reset 

func (x *ApplyResponse) Reset()

func (*ApplyResponse) String 

func (x *ApplyResponse) String() string

type Author 

type Author struct {
	Id        []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*Author) Descriptor deprecated 

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

Deprecated: Use Author.ProtoReflect.Descriptor instead.

func (*Author) GetId 

func (x *Author) GetId() []byte

func (*Author) GetSignature 

func (x *Author) GetSignature() []byte

func (*Author) ProtoMessage 

func (*Author) ProtoMessage()

func (*Author) ProtoReflect 

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

func (*Author) Reset 

func (x *Author) Reset()

func (*Author) String 

func (x *Author) String() string

type Command 

type Command struct {
	Op Command_Operation `protobuf:"varint,1,opt,name=op,proto3,enum=kubelt.Command_Operation" json:"op,omitempty"`
	// Types that are assignable to Node:
	//	*Command_User
	//	*Command_Link
	Node isCommand_Node `protobuf_oneof:"node"`
	// contains filtered or unexported fields
}

A change command NOTE: if commands get complex it may make sense to not use op but instead use specific commands like InsertUserCommand

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead. 

func (x *Command) GetLink() *LinkCommand

func (*Command) GetNode 

func (m *Command) GetNode() isCommand_Node

func (*Command) GetOp 

func (x *Command) GetOp() Command_Operation

func (*Command) GetUser 

func (x *Command) GetUser() *UserCommand

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

type CommandSettings 

type CommandSettings struct {
	Timeout int32 `protobuf:"varint,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandSettings) Descriptor deprecated 

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

Deprecated: Use CommandSettings.ProtoReflect.Descriptor instead.

func (*CommandSettings) GetTimeout 

func (x *CommandSettings) GetTimeout() int32

func (*CommandSettings) ProtoMessage 

func (*CommandSettings) ProtoMessage()

func (*CommandSettings) ProtoReflect 

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

func (*CommandSettings) Reset 

func (x *CommandSettings) Reset()

func (*CommandSettings) String 

func (x *CommandSettings) String() string
type Command_Link struct {
	Link *LinkCommand `protobuf:"bytes,6,opt,name=link,proto3,oneof"`
}

type Command_Operation 

type Command_Operation int32
const (
	Command_UPSERT Command_Operation = 0
	Command_DELETE Command_Operation = 1
	Command_LINK   Command_Operation = 2
	Command_UNLINK Command_Operation = 3
)

func (Command_Operation) Descriptor 

func (Command_Operation) Descriptor() protoreflect.EnumDescriptor

func (Command_Operation) Enum 

func (x Command_Operation) Enum() *Command_Operation

func (Command_Operation) EnumDescriptor deprecated 

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

Deprecated: Use Command_Operation.Descriptor instead.

func (Command_Operation) Number 

func (x Command_Operation) Number() protoreflect.EnumNumber

func (Command_Operation) String 

func (x Command_Operation) String() string

func (Command_Operation) Type 

func (Command_Operation) Type() protoreflect.EnumType

type Command_User 

type Command_User struct {
	User *UserCommand `protobuf:"bytes,4,opt,name=user,proto3,oneof"`
}

type Commands 

type Commands struct {
	Commands []*Command `protobuf:"bytes,1,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

A list of Commands

func (*Commands) Descriptor deprecated 

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

Deprecated: Use Commands.ProtoReflect.Descriptor instead.

func (*Commands) GetCommands 

func (x *Commands) GetCommands() []*Command

func (*Commands) ProtoMessage 

func (*Commands) ProtoMessage()

func (*Commands) ProtoReflect 

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

func (*Commands) Reset 

func (x *Commands) Reset()

func (*Commands) String 

func (x *Commands) String() string

type Error 

type Error struct {
	Code    int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Details *any.Any `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() int32

func (*Error) GetDetails 

func (x *Error) GetDetails() *any.Any

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type GetRequest 

type GetRequest struct {
	Params *QueryParams `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	Node   *Node        `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

Get

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetNode 

func (x *GetRequest) GetNode() *Node

func (*GetRequest) GetParams 

func (x *GetRequest) GetParams() *QueryParams

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Node  *Node  `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetError 

func (x *GetResponse) GetError() *Error

func (*GetResponse) GetNode 

func (x *GetResponse) GetNode() *Node

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string
type Header struct {
	ID          string        `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ApiVersion  string        `protobuf:"bytes,2,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"` // can I remove this
	Kind        string        `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	Author      *Author       `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
	Prev        string        `protobuf:"bytes,5,opt,name=prev,proto3" json:"prev,omitempty"` // the CID to the previous version
	Annotations []*Annotation `protobuf:"bytes,6,rep,name=annotations,proto3" json:"annotations,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetAnnotations 

func (x *Header) GetAnnotations() []*Annotation

func (*Header) GetApiVersion 

func (x *Header) GetApiVersion() string

func (*Header) GetAuthor 

func (x *Header) GetAuthor() *Author

func (*Header) GetID 

func (x *Header) GetID() string

func (*Header) GetKind 

func (x *Header) GetKind() string

func (*Header) GetPrev 

func (x *Header) GetPrev() string

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type HealthCheckRequest 

type HealthCheckRequest struct {
	// contains filtered or unexported fields
}

HealthCheck

func (*HealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect 

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

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (x *HealthCheckRequest) String() string

type HealthCheckResponse 

type HealthCheckResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetError 

func (x *HealthCheckResponse) GetError() *Error

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type KubeltClient 

type KubeltClient interface {
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	RegisterUser(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	Apply(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)
}

KubeltClient is the client API for Kubelt 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 NewKubeltClient 

func NewKubeltClient(cc grpc.ClientConnInterface) KubeltClient

type KubeltServer 

type KubeltServer interface {
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	RegisterUser(context.Context, *ApplyRequest) (*ApplyResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)
	// contains filtered or unexported methods
}

KubeltServer is the server API for Kubelt service. All implementations must embed UnimplementedKubeltServer for forward compatibility 

type Link struct {
	Source   string            `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Target   string            `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Kind     string            `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	Rank     int32             `protobuf:"varint,4,opt,name=rank,proto3" json:"rank,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Link) Descriptor deprecated 

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

Deprecated: Use Link.ProtoReflect.Descriptor instead.

func (*Link) GetKind 

func (x *Link) GetKind() string

func (*Link) GetMetadata 

func (x *Link) GetMetadata() map[string]string

func (*Link) GetRank 

func (x *Link) GetRank() int32

func (*Link) GetSource 

func (x *Link) GetSource() string

func (*Link) GetTarget 

func (x *Link) GetTarget() string

func (*Link) ProtoMessage 

func (*Link) ProtoMessage()

func (*Link) ProtoReflect 

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

func (*Link) Reset 

func (x *Link) Reset()

func (*Link) String 

func (x *Link) String() string

type LinkCommand 

type LinkCommand struct {
	Settings *CommandSettings `protobuf:"bytes,1,opt,name=settings,proto3" json:"settings,omitempty"`
	Header   *Header          `protobuf:"bytes,2,opt,name=header,proto3" json:"header,omitempty"`
	Link     *Link            `protobuf:"bytes,3,opt,name=link,proto3" json:"link,omitempty"`
	// contains filtered or unexported fields
}

func (*LinkCommand) Descriptor deprecated 

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

Deprecated: Use LinkCommand.ProtoReflect.Descriptor instead.

func (*LinkCommand) GetHeader 

func (x *LinkCommand) GetHeader() *Header
func (x *LinkCommand) GetLink() *Link

func (*LinkCommand) GetSettings 

func (x *LinkCommand) GetSettings() *CommandSettings

func (*LinkCommand) ProtoMessage 

func (*LinkCommand) ProtoMessage()

func (*LinkCommand) ProtoReflect 

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

func (*LinkCommand) Reset 

func (x *LinkCommand) Reset()

func (*LinkCommand) String 

func (x *LinkCommand) String() string
type Links struct {
	Links []*Link `protobuf:"bytes,1,rep,name=links,proto3" json:"links,omitempty"`
	// contains filtered or unexported fields
}

func (*Links) Descriptor deprecated 

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

Deprecated: Use Links.ProtoReflect.Descriptor instead. 

func (x *Links) GetLinks() []*Link

func (*Links) ProtoMessage 

func (*Links) ProtoMessage()

func (*Links) ProtoReflect 

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

func (*Links) Reset 

func (x *Links) Reset()

func (*Links) String 

func (x *Links) String() string

type Manifest 

type Manifest struct {
	Kind     string    `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"` // can I remove this if we have checks on "data"?
	Metadata *Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Types that are assignable to Data:
	//	*Manifest_User
	Data isManifest_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*Manifest) Descriptor deprecated 

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

Deprecated: Use Manifest.ProtoReflect.Descriptor instead.

func (*Manifest) GetData 

func (m *Manifest) GetData() isManifest_Data

func (*Manifest) GetKind 

func (x *Manifest) GetKind() string

func (*Manifest) GetMetadata 

func (x *Manifest) GetMetadata() *Metadata

func (*Manifest) GetUser 

func (x *Manifest) GetUser() *UserData

func (*Manifest) ProtoMessage 

func (*Manifest) ProtoMessage()

func (*Manifest) ProtoReflect 

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

func (*Manifest) Reset 

func (x *Manifest) Reset()

func (*Manifest) String 

func (x *Manifest) String() string

type Manifest_User 

type Manifest_User struct {
	User *UserData `protobuf:"bytes,3,opt,name=user,proto3,oneof"`
}

type Manifests 

type Manifests struct {

	// label, query params
	Manifests map[string]*Manifest `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

A list of manifests

func (*Manifests) Descriptor deprecated 

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

Deprecated: Use Manifests.ProtoReflect.Descriptor instead.

func (*Manifests) GetManifests 

func (x *Manifests) GetManifests() map[string]*Manifest

func (*Manifests) ProtoMessage 

func (*Manifests) ProtoMessage()

func (*Manifests) ProtoReflect 

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

func (*Manifests) Reset 

func (x *Manifests) Reset()

func (*Manifests) String 

func (x *Manifests) String() string

type Metadata 

type Metadata struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetDescription 

func (x *Metadata) GetDescription() string

func (*Metadata) GetName 

func (x *Metadata) GetName() string

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type Node 

type Node struct {
	Header   *Header   `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Metadata *Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Types that are assignable to Value:
	//	*Node_User
	//	*Node_Link
	Value isNode_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetHeader 

func (x *Node) GetHeader() *Header
func (x *Node) GetLink() *Link

func (*Node) GetMetadata 

func (x *Node) GetMetadata() *Metadata

func (*Node) GetUser 

func (x *Node) GetUser() *UserData

func (*Node) GetValue 

func (m *Node) GetValue() isNode_Value

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string
type Node_Link struct {
	Link *Link `protobuf:"bytes,7,opt,name=link,proto3,oneof"`
}

type Node_User 

type Node_User struct {
	User *UserData `protobuf:"bytes,5,opt,name=user,proto3,oneof"`
}

type QueryParams 

type QueryParams struct {
	Links bool `protobuf:"varint,1,opt,name=links,proto3" json:"links,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryParams) Descriptor deprecated 

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

Deprecated: Use QueryParams.ProtoReflect.Descriptor instead. 

func (x *QueryParams) GetLinks() bool

func (*QueryParams) ProtoMessage 

func (*QueryParams) ProtoMessage()

func (*QueryParams) ProtoReflect 

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

func (*QueryParams) Reset 

func (x *QueryParams) Reset()

func (*QueryParams) String 

func (x *QueryParams) String() string

type QueryRequest 

type QueryRequest struct {
	Params    *QueryParams `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	Manifests *Manifests   `protobuf:"bytes,2,opt,name=manifests,proto3" json:"manifests,omitempty"`
	// contains filtered or unexported fields
}

Query

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetManifests 

func (x *QueryRequest) GetManifests() *Manifests

func (*QueryRequest) GetParams 

func (x *QueryRequest) GetParams() *QueryParams

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

type QueryResponse struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Error *Error  `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetError 

func (x *QueryResponse) GetError() *Error

func (*QueryResponse) GetNodes 

func (x *QueryResponse) GetNodes() []*Node

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

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

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type RegisterRequest 

type RegisterRequest struct {
	User *UserCommand `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

Register

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetUser 

func (x *RegisterRequest) GetUser() *UserCommand

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type RegisterResponse 

type RegisterResponse struct {
	Node  *Node  `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponse) Descriptor deprecated 

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetError 

func (x *RegisterResponse) GetError() *Error

func (*RegisterResponse) GetNode 

func (x *RegisterResponse) GetNode() *Node

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect 

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

func (*RegisterResponse) Reset 

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (x *RegisterResponse) String() string

type UnimplementedKubeltServer 

type UnimplementedKubeltServer struct {
}

UnimplementedKubeltServer must be embedded to have forward compatible implementations.

func (UnimplementedKubeltServer) Apply 

func (UnimplementedKubeltServer) Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)

func (UnimplementedKubeltServer) Get 

func (UnimplementedKubeltServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedKubeltServer) HealthCheck 

func (UnimplementedKubeltServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

func (UnimplementedKubeltServer) Query 

func (UnimplementedKubeltServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

func (UnimplementedKubeltServer) RegisterUser 

func (UnimplementedKubeltServer) RegisterUser(context.Context, *ApplyRequest) (*ApplyResponse, error)

type UnsafeKubeltServer 

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

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

type UserCommand 

type UserCommand struct {
	Settings *CommandSettings `protobuf:"bytes,1,opt,name=settings,proto3" json:"settings,omitempty"`
	Header   *Header          `protobuf:"bytes,2,opt,name=header,proto3" json:"header,omitempty"`
	Metadata *Metadata        `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Data     *UserData        `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*UserCommand) Descriptor deprecated 

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

Deprecated: Use UserCommand.ProtoReflect.Descriptor instead.

func (*UserCommand) GetData 

func (x *UserCommand) GetData() *UserData

func (*UserCommand) GetHeader 

func (x *UserCommand) GetHeader() *Header

func (*UserCommand) GetMetadata 

func (x *UserCommand) GetMetadata() *Metadata

func (*UserCommand) GetSettings 

func (x *UserCommand) GetSettings() *CommandSettings

func (*UserCommand) ProtoMessage 

func (*UserCommand) ProtoMessage()

func (*UserCommand) ProtoReflect 

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

func (*UserCommand) Reset 

func (x *UserCommand) Reset()

func (*UserCommand) String 

func (x *UserCommand) String() string

type UserData 

type UserData struct {
	Name         *UserData_Name `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Email        string         `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"`
	PublicKey    []byte         `protobuf:"bytes,3,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	SignatureKey []byte         `protobuf:"bytes,4,opt,name=signatureKey,proto3" json:"signatureKey,omitempty"`
	// contains filtered or unexported fields
}

func (*UserData) Descriptor deprecated 

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

Deprecated: Use UserData.ProtoReflect.Descriptor instead.

func (*UserData) GetEmail 

func (x *UserData) GetEmail() string

func (*UserData) GetName 

func (x *UserData) GetName() *UserData_Name

func (*UserData) GetPublicKey 

func (x *UserData) GetPublicKey() []byte

func (*UserData) GetSignatureKey 

func (x *UserData) GetSignatureKey() []byte

func (*UserData) ProtoMessage 

func (*UserData) ProtoMessage()

func (*UserData) ProtoReflect 

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

func (*UserData) Reset 

func (x *UserData) Reset()

func (*UserData) String 

func (x *UserData) String() string

type UserData_Name 

type UserData_Name struct {
	First string `protobuf:"bytes,1,opt,name=first,proto3" json:"first,omitempty"`
	Last  string `protobuf:"bytes,2,opt,name=last,proto3" json:"last,omitempty"`
	// contains filtered or unexported fields
}

func (*UserData_Name) Descriptor deprecated 

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

Deprecated: Use UserData_Name.ProtoReflect.Descriptor instead.

func (*UserData_Name) GetFirst 

func (x *UserData_Name) GetFirst() string

func (*UserData_Name) GetLast 

func (x *UserData_Name) GetLast() string

func (*UserData_Name) ProtoMessage 

func (*UserData_Name) ProtoMessage()

func (*UserData_Name) ProtoReflect 

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

func (*UserData_Name) Reset 

func (x *UserData_Name) Reset()

func (*UserData_Name) String 

func (x *UserData_Name) String() string

Source Files

View all Source files

Directories

Path Synopsis
Package v1alpha1 is a generated GoMock package.
 Package v1alpha1 is a generated GoMock package.

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.