pbresource

package
v0.6.0 Latest Latest
Warning

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

Go to latest
Published: Feb 28, 2024 License: MPL-2.0 Imports: 14 Imported by: 22

Documentation

Overview

Code generated by protoc-gen-deepcopy. DO NOT EDIT.

Code generated by protoc-json-shim. DO NOT EDIT.

Code generated by protoc-gen-deepcopy. DO NOT EDIT.

Code generated by protoc-json-shim. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source
var (
	Scope_name = map[int32]string{
		0: "SCOPE_UNDEFINED",
		1: "SCOPE_CLUSTER",
		2: "SCOPE_PARTITION",
		3: "SCOPE_NAMESPACE",
	}
	Scope_value = map[string]int32{
		"SCOPE_UNDEFINED": 0,
		"SCOPE_CLUSTER":   1,
		"SCOPE_PARTITION": 2,
		"SCOPE_NAMESPACE": 3,
	}
)

Enum value maps for Scope.

View Source
var (
	AnnotationsMarshaler   = &protojson.MarshalOptions{}
	AnnotationsUnmarshaler = &protojson.UnmarshalOptions{DiscardUnknown: false}
)
View Source
var (
	Condition_State_name = map[int32]string{
		0: "STATE_UNKNOWN",
		1: "STATE_TRUE",
		2: "STATE_FALSE",
	}
	Condition_State_value = map[string]int32{
		"STATE_UNKNOWN": 0,
		"STATE_TRUE":    1,
		"STATE_FALSE":   2,
	}
)

Enum value maps for Condition_State.

View Source
var (
	ResourceMarshaler   = &protojson.MarshalOptions{}
	ResourceUnmarshaler = &protojson.UnmarshalOptions{DiscardUnknown: false}
)
View Source
var (
	// optional hashicorp.consul.resource.ResourceTypeSpec spec = 8500;
	E_Spec = &file_pbresource_annotations_proto_extTypes[0]
)

Extension fields to descriptorpb.MessageOptions.

View Source
var File_pbresource_annotations_proto protoreflect.FileDescriptor
View Source
var File_pbresource_resource_proto protoreflect.FileDescriptor
View Source
var ResourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hashicorp.consul.resource.ResourceService",
	HandlerType: (*ResourceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Read",
			Handler:    _ResourceService_Read_Handler,
		},
		{
			MethodName: "Write",
			Handler:    _ResourceService_Write_Handler,
		},
		{
			MethodName: "WriteStatus",
			Handler:    _ResourceService_WriteStatus_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ResourceService_List_Handler,
		},
		{
			MethodName: "ListByOwner",
			Handler:    _ResourceService_ListByOwner_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ResourceService_Delete_Handler,
		},
		{
			MethodName: "MutateAndValidate",
			Handler:    _ResourceService_MutateAndValidate_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchList",
			Handler:       _ResourceService_WatchList_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pbresource/resource.proto",
}

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

Functions

func RegisterResourceServiceServer

func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)

Types

type CloningResourceServiceClient added in v0.6.0

type CloningResourceServiceClient struct {
	ResourceServiceClient
}

CloningResourceServiceClient implements the ResourceServiceClient interface by wrapping another implementation and copying all protobuf messages that pass through the client. This is mainly useful to wrap the an in-process client to insulate users of that client from having to care about potential immutability of data they receive or having the server implementation mutate their internal memory.

func (CloningResourceServiceClient) Delete added in v0.6.0

func (CloningResourceServiceClient) IsCloningResourceServiceClient added in v0.6.0

func (c CloningResourceServiceClient) IsCloningResourceServiceClient() bool

IsCloningResourceServiceClient implements the IsCloningResourceServiceClient interface. This is only used to detect wrapped clients that would be double cloning data and prevent that.

func (CloningResourceServiceClient) List added in v0.6.0

func (CloningResourceServiceClient) ListByOwner added in v0.6.0

func (CloningResourceServiceClient) MutateAndValidate added in v0.6.0

func (CloningResourceServiceClient) Read added in v0.6.0

func (CloningResourceServiceClient) WatchList added in v0.6.0

func (CloningResourceServiceClient) Write added in v0.6.0

func (CloningResourceServiceClient) WriteStatus added in v0.6.0

type Condition

type Condition struct {

	// Type identifies the type of condition (e.g. "Invalid", "ResolvedRefs").
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// State represents the state of the condition (i.e. true/false/unknown).
	State Condition_State `protobuf:"varint,2,opt,name=state,proto3,enum=hashicorp.consul.resource.Condition_State" json:"state,omitempty"`
	// Reason provides more machine-readable details about the condition (e.g.
	// "InvalidProtocol").
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// Message contains a human-friendly description of the status.
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// Resource identifies which resource this condition relates to, when it is
	// not the core resource itself.
	Resource *Reference `protobuf:"bytes,5,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

Condition represents a discreet observation about a resource in relation to the current state of the system.

It is heavily inspired by Kubernetes' [conditions](https://bit.ly/3H9Y6IK) and the Gateway API [types and reasons](https://bit.ly/3n2PPiP).

func (*Condition) DeepCopy added in v0.5.1

func (in *Condition) DeepCopy() *Condition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Condition. Required by controller-gen.

func (*Condition) DeepCopyInterface added in v0.5.1

func (in *Condition) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Condition. Required by controller-gen.

func (*Condition) DeepCopyInto added in v0.5.1

func (in *Condition) DeepCopyInto(out *Condition)

DeepCopyInto supports using Condition within kubernetes types, where deepcopy-gen is used.

func (*Condition) Descriptor deprecated

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

Deprecated: Use Condition.ProtoReflect.Descriptor instead.

func (*Condition) GetMessage

func (x *Condition) GetMessage() string

func (*Condition) GetReason

func (x *Condition) GetReason() string

func (*Condition) GetResource

func (x *Condition) GetResource() *Reference

func (*Condition) GetState

func (x *Condition) GetState() Condition_State

func (*Condition) GetType

func (x *Condition) GetType() string

func (*Condition) MarshalBinary

func (msg *Condition) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*Condition) MarshalJSON added in v0.5.1

func (this *Condition) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Condition

func (*Condition) ProtoMessage

func (*Condition) ProtoMessage()

func (*Condition) ProtoReflect

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

func (*Condition) Reset

func (x *Condition) Reset()

func (*Condition) String

func (x *Condition) String() string

func (*Condition) UnmarshalBinary

func (msg *Condition) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*Condition) UnmarshalJSON added in v0.5.1

func (this *Condition) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Condition

type Condition_State

type Condition_State int32

State represents the state of the condition (i.e. true/false/unknown).

const (
	// STATE_UNKNOWN means that the state of the condition is unknown.
	//
	// buf:lint:ignore ENUM_ZERO_VALUE_SUFFIX
	Condition_STATE_UNKNOWN Condition_State = 0
	// STATE_TRUE means that the state of the condition is true.
	Condition_STATE_TRUE Condition_State = 1
	// STATE_FALSE means that the state of the condition is false.
	Condition_STATE_FALSE Condition_State = 2
)

func (Condition_State) Descriptor

func (Condition_State) Enum

func (x Condition_State) Enum() *Condition_State

func (Condition_State) EnumDescriptor deprecated

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

Deprecated: Use Condition_State.Descriptor instead.

func (Condition_State) Number

func (Condition_State) String

func (x Condition_State) String() string

func (Condition_State) Type

type DeleteRequest

type DeleteRequest struct {

	// ID of the resource that will be deleted.
	Id *ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Version may be provided to perform a CAS (Compare-And-Swap) deletion of the
	// resource. If the given version doesn't match what is currently stored, an
	// Aborted error code will be returned.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

DeleteRequest contains the parameters to the Delete endpoint.

func (*DeleteRequest) DeepCopy added in v0.5.1

func (in *DeleteRequest) DeepCopy() *DeleteRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeleteRequest. Required by controller-gen.

func (*DeleteRequest) DeepCopyInterface added in v0.5.1

func (in *DeleteRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new DeleteRequest. Required by controller-gen.

func (*DeleteRequest) DeepCopyInto added in v0.5.1

func (in *DeleteRequest) DeepCopyInto(out *DeleteRequest)

DeepCopyInto supports using DeleteRequest within kubernetes types, where deepcopy-gen is used.

func (*DeleteRequest) Descriptor deprecated

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetId

func (x *DeleteRequest) GetId() *ID

func (*DeleteRequest) GetVersion

func (x *DeleteRequest) GetVersion() string

func (*DeleteRequest) MarshalBinary

func (msg *DeleteRequest) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*DeleteRequest) MarshalJSON added in v0.5.1

func (this *DeleteRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for DeleteRequest

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect

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

func (*DeleteRequest) Reset

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String

func (x *DeleteRequest) String() string

func (*DeleteRequest) UnmarshalBinary

func (msg *DeleteRequest) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*DeleteRequest) UnmarshalJSON added in v0.5.1

func (this *DeleteRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for DeleteRequest

type DeleteResponse

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

DeleteResponse contains the results of calling the Delete endpoint.

func (*DeleteResponse) DeepCopy added in v0.5.1

func (in *DeleteResponse) DeepCopy() *DeleteResponse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeleteResponse. Required by controller-gen.

func (*DeleteResponse) DeepCopyInterface added in v0.5.1

func (in *DeleteResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new DeleteResponse. Required by controller-gen.

func (*DeleteResponse) DeepCopyInto added in v0.5.1

func (in *DeleteResponse) DeepCopyInto(out *DeleteResponse)

DeepCopyInto supports using DeleteResponse within kubernetes types, where deepcopy-gen is used.

func (*DeleteResponse) Descriptor deprecated

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) MarshalBinary

func (msg *DeleteResponse) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*DeleteResponse) MarshalJSON added in v0.5.1

func (this *DeleteResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for DeleteResponse

func (*DeleteResponse) ProtoMessage

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect

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

func (*DeleteResponse) Reset

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String

func (x *DeleteResponse) String() string

func (*DeleteResponse) UnmarshalBinary

func (msg *DeleteResponse) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*DeleteResponse) UnmarshalJSON added in v0.5.1

func (this *DeleteResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for DeleteResponse

type ID

type ID struct {

	// Uid is the unique internal identifier we gave to the resource.
	//
	// It is primarily used to tell the difference between the current resource
	// and previous deleted resources with the same user-given name.
	//
	// Concretely, Uid is a [ULID](https://github.com/ulid/spec) and you can treat
	// its timestamp component as the resource's creation time.
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// Name is the user-given name of the resource (e.g. the "billing" service).
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Type identifies the resource's type.
	Type *Type `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// Tenancy identifies the tenancy units (i.e. partition, namespace) in which
	// the resource resides.
	Tenancy *Tenancy `protobuf:"bytes,4,opt,name=tenancy,proto3" json:"tenancy,omitempty"`
	// contains filtered or unexported fields
}

ID uniquely identifies a resource.

func (*ID) DeepCopy added in v0.5.1

func (in *ID) DeepCopy() *ID

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ID. Required by controller-gen.

func (*ID) DeepCopyInterface added in v0.5.1

func (in *ID) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ID. Required by controller-gen.

func (*ID) DeepCopyInto added in v0.5.1

func (in *ID) DeepCopyInto(out *ID)

DeepCopyInto supports using ID within kubernetes types, where deepcopy-gen is used.

func (*ID) Descriptor deprecated

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

Deprecated: Use ID.ProtoReflect.Descriptor instead.

func (*ID) GetName

func (x *ID) GetName() string

func (*ID) GetTenancy

func (x *ID) GetTenancy() *Tenancy

func (*ID) GetType

func (x *ID) GetType() *Type

func (*ID) GetUid

func (x *ID) GetUid() string

func (*ID) MarshalBinary

func (msg *ID) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ID) MarshalJSON added in v0.5.1

func (this *ID) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ID

func (*ID) ProtoMessage

func (*ID) ProtoMessage()

func (*ID) ProtoReflect

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

func (*ID) Reset

func (x *ID) Reset()

func (*ID) String

func (x *ID) String() string

func (*ID) UnmarshalBinary

func (msg *ID) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*ID) UnmarshalJSON added in v0.5.1

func (this *ID) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ID

type IsCloningResourceServiceClient added in v0.6.0

type IsCloningResourceServiceClient interface {
	IsCloningResourceServiceClient() bool
}

IsCloningResourceServiceClient is an interface that can be used to detect that a ResourceServiceClient is using the in-memory transport and has already been wrapped with a with a CloningResourceServiceClient.

type ListByOwnerRequest

type ListByOwnerRequest struct {
	Owner *ID `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

ListByOwnerRequest contains the parameters to the ListByOwner endpoint.

func (*ListByOwnerRequest) DeepCopy added in v0.5.1

func (in *ListByOwnerRequest) DeepCopy() *ListByOwnerRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ListByOwnerRequest. Required by controller-gen.

func (*ListByOwnerRequest) DeepCopyInterface added in v0.5.1

func (in *ListByOwnerRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ListByOwnerRequest. Required by controller-gen.

func (*ListByOwnerRequest) DeepCopyInto added in v0.5.1

func (in *ListByOwnerRequest) DeepCopyInto(out *ListByOwnerRequest)

DeepCopyInto supports using ListByOwnerRequest within kubernetes types, where deepcopy-gen is used.

func (*ListByOwnerRequest) Descriptor deprecated

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

Deprecated: Use ListByOwnerRequest.ProtoReflect.Descriptor instead.

func (*ListByOwnerRequest) GetOwner

func (x *ListByOwnerRequest) GetOwner() *ID

func (*ListByOwnerRequest) MarshalBinary

func (msg *ListByOwnerRequest) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ListByOwnerRequest) MarshalJSON added in v0.5.1

func (this *ListByOwnerRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ListByOwnerRequest

func (*ListByOwnerRequest) ProtoMessage

func (*ListByOwnerRequest) ProtoMessage()

func (*ListByOwnerRequest) ProtoReflect

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

func (*ListByOwnerRequest) Reset

func (x *ListByOwnerRequest) Reset()

func (*ListByOwnerRequest) String

func (x *ListByOwnerRequest) String() string

func (*ListByOwnerRequest) UnmarshalBinary

func (msg *ListByOwnerRequest) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*ListByOwnerRequest) UnmarshalJSON added in v0.5.1

func (this *ListByOwnerRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ListByOwnerRequest

type ListByOwnerResponse

type ListByOwnerResponse struct {

	// Resources that were listed.
	Resources []*Resource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

ListByOwnerResponse contains the results of calling the ListByOwner endpoint.

func (*ListByOwnerResponse) DeepCopy added in v0.5.1

func (in *ListByOwnerResponse) DeepCopy() *ListByOwnerResponse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ListByOwnerResponse. Required by controller-gen.

func (*ListByOwnerResponse) DeepCopyInterface added in v0.5.1

func (in *ListByOwnerResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ListByOwnerResponse. Required by controller-gen.

func (*ListByOwnerResponse) DeepCopyInto added in v0.5.1

func (in *ListByOwnerResponse) DeepCopyInto(out *ListByOwnerResponse)

DeepCopyInto supports using ListByOwnerResponse within kubernetes types, where deepcopy-gen is used.

func (*ListByOwnerResponse) Descriptor deprecated

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

Deprecated: Use ListByOwnerResponse.ProtoReflect.Descriptor instead.

func (*ListByOwnerResponse) GetResources

func (x *ListByOwnerResponse) GetResources() []*Resource

func (*ListByOwnerResponse) MarshalBinary

func (msg *ListByOwnerResponse) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ListByOwnerResponse) MarshalJSON added in v0.5.1

func (this *ListByOwnerResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ListByOwnerResponse

func (*ListByOwnerResponse) ProtoMessage

func (*ListByOwnerResponse) ProtoMessage()

func (*ListByOwnerResponse) ProtoReflect

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

func (*ListByOwnerResponse) Reset

func (x *ListByOwnerResponse) Reset()

func (*ListByOwnerResponse) String

func (x *ListByOwnerResponse) String() string

func (*ListByOwnerResponse) UnmarshalBinary

func (msg *ListByOwnerResponse) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*ListByOwnerResponse) UnmarshalJSON added in v0.5.1

func (this *ListByOwnerResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ListByOwnerResponse

type ListRequest

type ListRequest struct {

	// Type of resource to list.
	Type *Type `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Tenancy units in which to list resources. To list resources in all units,
	// provide the wildcard "*" value.
	Tenancy *Tenancy `protobuf:"bytes,2,opt,name=tenancy,proto3" json:"tenancy,omitempty"`
	// NamePrefix filters the results to those with a name beginning with the
	// given prefix.
	NamePrefix string `protobuf:"bytes,3,opt,name=name_prefix,json=namePrefix,proto3" json:"name_prefix,omitempty"`
	// contains filtered or unexported fields
}

ListRequest contains the parameters to the List endpoint.

func (*ListRequest) DeepCopy added in v0.5.1

func (in *ListRequest) DeepCopy() *ListRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ListRequest. Required by controller-gen.

func (*ListRequest) DeepCopyInterface added in v0.5.1

func (in *ListRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ListRequest. Required by controller-gen.

func (*ListRequest) DeepCopyInto added in v0.5.1

func (in *ListRequest) DeepCopyInto(out *ListRequest)

DeepCopyInto supports using ListRequest within kubernetes types, where deepcopy-gen is used.

func (*ListRequest) Descriptor deprecated

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetNamePrefix

func (x *ListRequest) GetNamePrefix() string

func (*ListRequest) GetTenancy

func (x *ListRequest) GetTenancy() *Tenancy

func (*ListRequest) GetType

func (x *ListRequest) GetType() *Type

func (*ListRequest) MarshalBinary

func (msg *ListRequest) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ListRequest) MarshalJSON added in v0.5.1

func (this *ListRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ListRequest

func (*ListRequest) ProtoMessage

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect

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

func (*ListRequest) Reset

func (x *ListRequest) Reset()

func (*ListRequest) String

func (x *ListRequest) String() string

func (*ListRequest) UnmarshalBinary

func (msg *ListRequest) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*ListRequest) UnmarshalJSON added in v0.5.1

func (this *ListRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ListRequest

type ListResponse

type ListResponse struct {

	// Resources that were listed.
	Resources []*Resource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

ListResponse contains the results of calling the List endpoint.

func (*ListResponse) DeepCopy added in v0.5.1

func (in *ListResponse) DeepCopy() *ListResponse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ListResponse. Required by controller-gen.

func (*ListResponse) DeepCopyInterface added in v0.5.1

func (in *ListResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ListResponse. Required by controller-gen.

func (*ListResponse) DeepCopyInto added in v0.5.1

func (in *ListResponse) DeepCopyInto(out *ListResponse)

DeepCopyInto supports using ListResponse within kubernetes types, where deepcopy-gen is used.

func (*ListResponse) Descriptor deprecated

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetResources

func (x *ListResponse) GetResources() []*Resource

func (*ListResponse) MarshalBinary

func (msg *ListResponse) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ListResponse) MarshalJSON added in v0.5.1

func (this *ListResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ListResponse

func (*ListResponse) ProtoMessage

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect

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

func (*ListResponse) Reset

func (x *ListResponse) Reset()

func (*ListResponse) String

func (x *ListResponse) String() string

func (*ListResponse) UnmarshalBinary

func (msg *ListResponse) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*ListResponse) UnmarshalJSON added in v0.5.1

func (this *ListResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ListResponse

type MutateAndValidateRequest added in v0.6.0

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

MutateAndValidateRequest contains the parameters to the MutateAndValidate endpoint.

func (*MutateAndValidateRequest) DeepCopy added in v0.6.0

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MutateAndValidateRequest. Required by controller-gen.

func (*MutateAndValidateRequest) DeepCopyInterface added in v0.6.0

func (in *MutateAndValidateRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new MutateAndValidateRequest. Required by controller-gen.

func (*MutateAndValidateRequest) DeepCopyInto added in v0.6.0

func (in *MutateAndValidateRequest) DeepCopyInto(out *MutateAndValidateRequest)

DeepCopyInto supports using MutateAndValidateRequest within kubernetes types, where deepcopy-gen is used.

func (*MutateAndValidateRequest) Descriptor deprecated added in v0.6.0

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

Deprecated: Use MutateAndValidateRequest.ProtoReflect.Descriptor instead.

func (*MutateAndValidateRequest) GetResource added in v0.6.0

func (x *MutateAndValidateRequest) GetResource() *Resource

func (*MutateAndValidateRequest) MarshalBinary added in v0.6.0

func (msg *MutateAndValidateRequest) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*MutateAndValidateRequest) MarshalJSON added in v0.6.0

func (this *MutateAndValidateRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for MutateAndValidateRequest

func (*MutateAndValidateRequest) ProtoMessage added in v0.6.0

func (*MutateAndValidateRequest) ProtoMessage()

func (*MutateAndValidateRequest) ProtoReflect added in v0.6.0

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

func (*MutateAndValidateRequest) Reset added in v0.6.0

func (x *MutateAndValidateRequest) Reset()

func (*MutateAndValidateRequest) String added in v0.6.0

func (x *MutateAndValidateRequest) String() string

func (*MutateAndValidateRequest) UnmarshalBinary added in v0.6.0

func (msg *MutateAndValidateRequest) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*MutateAndValidateRequest) UnmarshalJSON added in v0.6.0

func (this *MutateAndValidateRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for MutateAndValidateRequest

type MutateAndValidateResponse added in v0.6.0

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

MutateAndValidateResponse contains the results of calling the MutateAndValidate endpoint.

func (*MutateAndValidateResponse) DeepCopy added in v0.6.0

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MutateAndValidateResponse. Required by controller-gen.

func (*MutateAndValidateResponse) DeepCopyInterface added in v0.6.0

func (in *MutateAndValidateResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new MutateAndValidateResponse. Required by controller-gen.

func (*MutateAndValidateResponse) DeepCopyInto added in v0.6.0

DeepCopyInto supports using MutateAndValidateResponse within kubernetes types, where deepcopy-gen is used.

func (*MutateAndValidateResponse) Descriptor deprecated added in v0.6.0

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

Deprecated: Use MutateAndValidateResponse.ProtoReflect.Descriptor instead.

func (*MutateAndValidateResponse) GetResource added in v0.6.0

func (x *MutateAndValidateResponse) GetResource() *Resource

func (*MutateAndValidateResponse) MarshalBinary added in v0.6.0

func (msg *MutateAndValidateResponse) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*MutateAndValidateResponse) MarshalJSON added in v0.6.0

func (this *MutateAndValidateResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for MutateAndValidateResponse

func (*MutateAndValidateResponse) ProtoMessage added in v0.6.0

func (*MutateAndValidateResponse) ProtoMessage()

func (*MutateAndValidateResponse) ProtoReflect added in v0.6.0

func (*MutateAndValidateResponse) Reset added in v0.6.0

func (x *MutateAndValidateResponse) Reset()

func (*MutateAndValidateResponse) String added in v0.6.0

func (x *MutateAndValidateResponse) String() string

func (*MutateAndValidateResponse) UnmarshalBinary added in v0.6.0

func (msg *MutateAndValidateResponse) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*MutateAndValidateResponse) UnmarshalJSON added in v0.6.0

func (this *MutateAndValidateResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for MutateAndValidateResponse

type ReadRequest

type ReadRequest struct {

	// ID of the resource.
	Id *ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

ReadRequest contains the parameters to the Read endpoint.

func (*ReadRequest) DeepCopy added in v0.5.1

func (in *ReadRequest) DeepCopy() *ReadRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReadRequest. Required by controller-gen.

func (*ReadRequest) DeepCopyInterface added in v0.5.1

func (in *ReadRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ReadRequest. Required by controller-gen.

func (*ReadRequest) DeepCopyInto added in v0.5.1

func (in *ReadRequest) DeepCopyInto(out *ReadRequest)

DeepCopyInto supports using ReadRequest within kubernetes types, where deepcopy-gen is used.

func (*ReadRequest) Descriptor deprecated

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetId

func (x *ReadRequest) GetId() *ID

func (*ReadRequest) MarshalBinary

func (msg *ReadRequest) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ReadRequest) MarshalJSON added in v0.5.1

func (this *ReadRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ReadRequest

func (*ReadRequest) ProtoMessage

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect

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

func (*ReadRequest) Reset

func (x *ReadRequest) Reset()

func (*ReadRequest) String

func (x *ReadRequest) String() string

func (*ReadRequest) UnmarshalBinary

func (msg *ReadRequest) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*ReadRequest) UnmarshalJSON added in v0.5.1

func (this *ReadRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ReadRequest

type ReadResponse

type ReadResponse struct {

	// Resource that was read.
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

ReadResponse contains the results of calling the Read endpoint.

func (*ReadResponse) DeepCopy added in v0.5.1

func (in *ReadResponse) DeepCopy() *ReadResponse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReadResponse. Required by controller-gen.

func (*ReadResponse) DeepCopyInterface added in v0.5.1

func (in *ReadResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ReadResponse. Required by controller-gen.

func (*ReadResponse) DeepCopyInto added in v0.5.1

func (in *ReadResponse) DeepCopyInto(out *ReadResponse)

DeepCopyInto supports using ReadResponse within kubernetes types, where deepcopy-gen is used.

func (*ReadResponse) Descriptor deprecated

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

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetResource

func (x *ReadResponse) GetResource() *Resource

func (*ReadResponse) MarshalBinary

func (msg *ReadResponse) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ReadResponse) MarshalJSON added in v0.5.1

func (this *ReadResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ReadResponse

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect

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

func (*ReadResponse) Reset

func (x *ReadResponse) Reset()

func (*ReadResponse) String

func (x *ReadResponse) String() string

func (*ReadResponse) UnmarshalBinary

func (msg *ReadResponse) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*ReadResponse) UnmarshalJSON added in v0.5.1

func (this *ReadResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ReadResponse

type Reference

type Reference struct {

	// Type identifies the resource's type.
	Type *Type `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Tenancy identifies the tenancy units (i.e. partition, namespace) in which
	// the resource resides.
	Tenancy *Tenancy `protobuf:"bytes,2,opt,name=tenancy,proto3" json:"tenancy,omitempty"`
	// Name is the user-given name of the resource (e.g. the "billing" service).
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Section identifies which part of the resource the condition relates to.
	Section string `protobuf:"bytes,4,opt,name=section,proto3" json:"section,omitempty"`
	// contains filtered or unexported fields
}

Reference identifies which resource a condition relates to, when it is not the core resource itself.

func (*Reference) DeepCopy added in v0.5.1

func (in *Reference) DeepCopy() *Reference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Reference. Required by controller-gen.

func (*Reference) DeepCopyInterface added in v0.5.1

func (in *Reference) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Reference. Required by controller-gen.

func (*Reference) DeepCopyInto added in v0.5.1

func (in *Reference) DeepCopyInto(out *Reference)

DeepCopyInto supports using Reference within kubernetes types, where deepcopy-gen is used.

func (*Reference) Descriptor deprecated

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

Deprecated: Use Reference.ProtoReflect.Descriptor instead.

func (*Reference) GetName

func (x *Reference) GetName() string

func (*Reference) GetSection

func (x *Reference) GetSection() string

func (*Reference) GetTenancy

func (x *Reference) GetTenancy() *Tenancy

func (*Reference) GetType

func (x *Reference) GetType() *Type

func (*Reference) MarshalBinary

func (msg *Reference) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*Reference) MarshalJSON added in v0.5.1

func (this *Reference) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Reference

func (*Reference) ProtoMessage

func (*Reference) ProtoMessage()

func (*Reference) ProtoReflect

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

func (*Reference) Reset

func (x *Reference) Reset()

func (*Reference) String

func (x *Reference) String() string

func (*Reference) UnmarshalBinary

func (msg *Reference) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*Reference) UnmarshalJSON added in v0.5.1

func (this *Reference) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Reference

type Resource

type Resource struct {

	// ID uniquely identifies the resource.
	Id *ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Owner (optionally) describes which resource "owns" this resource, it is
	// immutable and can only be set on resource creation. Owned resources will
	// be automatically deleted when their owner is deleted.
	Owner *ID `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	// Version is the low-level version identifier used by the storage backend
	// in CAS (Compare-And-Swap) operations. It will change when the resource is
	// modified in any way, including status updates.
	//
	// When calling the Write endpoint, providing a non-blank version will perform
	// a CAS (Compare-And-Swap) write, which will result in an Aborted error code
	// if the given version doesn't match what is stored.
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// Generation is incremented whenever the resource's content (i.e. not its
	// status) is modified. You can think of it as being the "user version".
	//
	// Concretely, Generation is a [ULID](https://github.com/ulid/spec) and you
	// can treat its timestamp component as the resource's modification time.
	Generation string `protobuf:"bytes,4,opt,name=generation,proto3" json:"generation,omitempty"`
	// Metadata contains key/value pairs of arbitrary metadata about the resource.
	// "deletionTimestamp" and "finalizers" keys are reserved for internal use.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Status is used by controllers to communicate the result of attempting to
	// reconcile and apply the resource (e.g. surface semantic validation errors)
	// with users and other controllers. Each status is identified by a unique key
	// and should only ever be updated by one controller.
	//
	// Status can only be updated via the WriteStatus endpoint. Attempting to do
	// so via the Write endpoint will result in an InvalidArgument error code.
	Status map[string]*Status `` /* 153-byte string literal not displayed */
	// Data contains the resource's type-specific content.
	Data *anypb.Any `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Resource describes a resource of a known type managed by Consul.

func (*Resource) DeepCopy added in v0.5.1

func (in *Resource) DeepCopy() *Resource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Resource. Required by controller-gen.

func (*Resource) DeepCopyInterface added in v0.5.1

func (in *Resource) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Resource. Required by controller-gen.

func (*Resource) DeepCopyInto added in v0.5.1

func (in *Resource) DeepCopyInto(out *Resource)

DeepCopyInto supports using Resource within kubernetes types, where deepcopy-gen is used.

func (*Resource) Descriptor deprecated

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetData

func (x *Resource) GetData() *anypb.Any

func (*Resource) GetGeneration

func (x *Resource) GetGeneration() string

func (*Resource) GetId

func (x *Resource) GetId() *ID

func (*Resource) GetMetadata

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

func (*Resource) GetOwner

func (x *Resource) GetOwner() *ID

func (*Resource) GetStatus

func (x *Resource) GetStatus() map[string]*Status

func (*Resource) GetVersion

func (x *Resource) GetVersion() string

func (*Resource) MarshalBinary

func (msg *Resource) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*Resource) MarshalJSON added in v0.5.1

func (this *Resource) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Resource

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect

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

func (*Resource) Reset

func (x *Resource) Reset()

func (*Resource) String

func (x *Resource) String() string

func (*Resource) UnmarshalBinary

func (msg *Resource) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*Resource) UnmarshalJSON added in v0.5.1

func (this *Resource) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Resource

type ResourceServiceClient

type ResourceServiceClient interface {
	// Read a resource by ID.
	//
	// By default, reads are eventually consistent, but you can opt-in to strong
	// consistency via the x-consul-consistency-mode metadata (see ResourceService
	// docs for more info).
	//
	// Errors with NotFound if the resource is not found.
	//
	// Errors with InvalidArgument if the request fails validation or the resource
	// is stored as a type with a different GroupVersion than was requested.
	//
	// Errors with PermissionDenied if the caller is not authorized to read
	// the resource.
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	// Write a resource.
	//
	// To perform a CAS (Compare-And-Swap) write, provide the current resource
	// version in the Resource.Version field. If the given version doesn't match
	// what is currently stored, an Aborted error code will be returned.
	//
	// To perform a blanket write (update regardless of the stored version),
	// provide an empty Version in the Resource.Version field. Note that the
	// write may still fail due to not being able to internally do a CAS write
	// and return an Aborted error code.
	//
	// Resource.Id.Uid can (and by controllers, should) be provided to avoid
	// accidentally modifying a resource if it has been deleted and recreated.
	// If the given Uid doesn't match what is stored, a FailedPrecondition error
	// code will be returned.
	//
	// It is not possible to modify the resource's status using Write. You must
	// use WriteStatus instead.
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	// WriteStatus updates one of the resource's statuses. It should only be used
	// by controllers.
	//
	// To perform a CAS (Compare-And-Swap) write, provide the current resource
	// version in the Version field. If the given version doesn't match what is
	// currently stored, an Aborted error code will be returned.
	//
	// Note: in most cases, CAS status updates are not necessary because updates
	// are scoped to a specific status key and controllers are leader-elected so
	// there is no chance of a conflict.
	//
	// Id.Uid must be provided to avoid accidentally modifying a resource if it has
	// been deleted and recreated. If the given Uid doesn't match what is stored,
	// a FailedPrecondition error code will be returned.
	WriteStatus(ctx context.Context, in *WriteStatusRequest, opts ...grpc.CallOption) (*WriteStatusResponse, error)
	// List resources of a given type, tenancy, and optionally name prefix.
	//
	// To list resources across all tenancy units, provide the wildcard "*" value.
	//
	// Results are eventually consistent (see ResourceService docs for more info).
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	// List resources of a given owner.
	//
	// Results are eventually consistent (see ResourceService docs for more info).
	ListByOwner(ctx context.Context, in *ListByOwnerRequest, opts ...grpc.CallOption) (*ListByOwnerResponse, error)
	// Delete a resource by ID.
	//
	// Deleting a non-existent resource will return a successful response for
	// idempotency.
	//
	// To perform a CAS (Compare-And-Swap) deletion, provide the current resource
	// version in the Version field. If the given version doesn't match what is
	// currently stored, an Aborted error code will be returned.
	//
	// Resource.Id.Uid can (and by controllers, should) be provided to avoid
	// accidentally modifying a resource if it has been deleted and recreated.
	// If the given Uid doesn't match what is stored, a FailedPrecondition error
	// code will be returned.
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// WatchList watches resources of the given type, tenancy, and optionally name
	// prefix. It returns results for the current state-of-the-world at the start
	// of the stream, and delta events whenever resources are written or deleted.
	//
	// To watch resources across all tenancy units, provide the wildcard "*" value.
	//
	// WatchList makes no guarantees about event timeliness (e.g. an event for a
	// write may not be received immediately), but it does guarantee that events
	// will be emitted in the correct order. See ResourceService docs for more
	// info about consistency guarentees.
	//
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	WatchList(ctx context.Context, in *WatchListRequest, opts ...grpc.CallOption) (ResourceService_WatchListClient, error)
	// MutateAndValidate a resource.
	//
	// Applies a resource type's registered mutation and validation hooks to
	// a resource. This is useful for filling in defaults and validating inputs before
	// doing a Write. It's not a pre-requisite since the Write endpoint will also apply
	// the hooks.
	MutateAndValidate(ctx context.Context, in *MutateAndValidateRequest, opts ...grpc.CallOption) (*MutateAndValidateResponse, error)
}

ResourceServiceClient is the client API for ResourceService 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 NewCloningResourceServiceClient added in v0.6.0

func NewCloningResourceServiceClient(client ResourceServiceClient) ResourceServiceClient

type ResourceServiceServer

type ResourceServiceServer interface {
	// Read a resource by ID.
	//
	// By default, reads are eventually consistent, but you can opt-in to strong
	// consistency via the x-consul-consistency-mode metadata (see ResourceService
	// docs for more info).
	//
	// Errors with NotFound if the resource is not found.
	//
	// Errors with InvalidArgument if the request fails validation or the resource
	// is stored as a type with a different GroupVersion than was requested.
	//
	// Errors with PermissionDenied if the caller is not authorized to read
	// the resource.
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	// Write a resource.
	//
	// To perform a CAS (Compare-And-Swap) write, provide the current resource
	// version in the Resource.Version field. If the given version doesn't match
	// what is currently stored, an Aborted error code will be returned.
	//
	// To perform a blanket write (update regardless of the stored version),
	// provide an empty Version in the Resource.Version field. Note that the
	// write may still fail due to not being able to internally do a CAS write
	// and return an Aborted error code.
	//
	// Resource.Id.Uid can (and by controllers, should) be provided to avoid
	// accidentally modifying a resource if it has been deleted and recreated.
	// If the given Uid doesn't match what is stored, a FailedPrecondition error
	// code will be returned.
	//
	// It is not possible to modify the resource's status using Write. You must
	// use WriteStatus instead.
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	// WriteStatus updates one of the resource's statuses. It should only be used
	// by controllers.
	//
	// To perform a CAS (Compare-And-Swap) write, provide the current resource
	// version in the Version field. If the given version doesn't match what is
	// currently stored, an Aborted error code will be returned.
	//
	// Note: in most cases, CAS status updates are not necessary because updates
	// are scoped to a specific status key and controllers are leader-elected so
	// there is no chance of a conflict.
	//
	// Id.Uid must be provided to avoid accidentally modifying a resource if it has
	// been deleted and recreated. If the given Uid doesn't match what is stored,
	// a FailedPrecondition error code will be returned.
	WriteStatus(context.Context, *WriteStatusRequest) (*WriteStatusResponse, error)
	// List resources of a given type, tenancy, and optionally name prefix.
	//
	// To list resources across all tenancy units, provide the wildcard "*" value.
	//
	// Results are eventually consistent (see ResourceService docs for more info).
	List(context.Context, *ListRequest) (*ListResponse, error)
	// List resources of a given owner.
	//
	// Results are eventually consistent (see ResourceService docs for more info).
	ListByOwner(context.Context, *ListByOwnerRequest) (*ListByOwnerResponse, error)
	// Delete a resource by ID.
	//
	// Deleting a non-existent resource will return a successful response for
	// idempotency.
	//
	// To perform a CAS (Compare-And-Swap) deletion, provide the current resource
	// version in the Version field. If the given version doesn't match what is
	// currently stored, an Aborted error code will be returned.
	//
	// Resource.Id.Uid can (and by controllers, should) be provided to avoid
	// accidentally modifying a resource if it has been deleted and recreated.
	// If the given Uid doesn't match what is stored, a FailedPrecondition error
	// code will be returned.
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// WatchList watches resources of the given type, tenancy, and optionally name
	// prefix. It returns results for the current state-of-the-world at the start
	// of the stream, and delta events whenever resources are written or deleted.
	//
	// To watch resources across all tenancy units, provide the wildcard "*" value.
	//
	// WatchList makes no guarantees about event timeliness (e.g. an event for a
	// write may not be received immediately), but it does guarantee that events
	// will be emitted in the correct order. See ResourceService docs for more
	// info about consistency guarentees.
	//
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	WatchList(*WatchListRequest, ResourceService_WatchListServer) error
	// MutateAndValidate a resource.
	//
	// Applies a resource type's registered mutation and validation hooks to
	// a resource. This is useful for filling in defaults and validating inputs before
	// doing a Write. It's not a pre-requisite since the Write endpoint will also apply
	// the hooks.
	MutateAndValidate(context.Context, *MutateAndValidateRequest) (*MutateAndValidateResponse, error)
}

ResourceServiceServer is the server API for ResourceService service. All implementations should embed UnimplementedResourceServiceServer for forward compatibility

type ResourceService_WatchListClient

type ResourceService_WatchListClient interface {
	Recv() (*WatchEvent, error)
	grpc.ClientStream
}

type ResourceService_WatchListServer

type ResourceService_WatchListServer interface {
	Send(*WatchEvent) error
	grpc.ServerStream
}

type ResourceTypeSpec added in v0.5.1

type ResourceTypeSpec struct {
	Scope       Scope `protobuf:"varint,1,opt,name=scope,proto3,enum=hashicorp.consul.resource.Scope" json:"scope,omitempty"`
	DontMapHttp bool  `protobuf:"varint,2,opt,name=dont_map_http,json=dontMapHttp,proto3" json:"dont_map_http,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceTypeSpec) DeepCopy added in v0.5.1

func (in *ResourceTypeSpec) DeepCopy() *ResourceTypeSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceTypeSpec. Required by controller-gen.

func (*ResourceTypeSpec) DeepCopyInterface added in v0.5.1

func (in *ResourceTypeSpec) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ResourceTypeSpec. Required by controller-gen.

func (*ResourceTypeSpec) DeepCopyInto added in v0.5.1

func (in *ResourceTypeSpec) DeepCopyInto(out *ResourceTypeSpec)

DeepCopyInto supports using ResourceTypeSpec within kubernetes types, where deepcopy-gen is used.

func (*ResourceTypeSpec) Descriptor deprecated added in v0.5.1

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

Deprecated: Use ResourceTypeSpec.ProtoReflect.Descriptor instead.

func (*ResourceTypeSpec) GetDontMapHttp added in v0.5.1

func (x *ResourceTypeSpec) GetDontMapHttp() bool

func (*ResourceTypeSpec) GetScope added in v0.5.1

func (x *ResourceTypeSpec) GetScope() Scope

func (*ResourceTypeSpec) MarshalBinary added in v0.5.1

func (msg *ResourceTypeSpec) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ResourceTypeSpec) MarshalJSON added in v0.5.1

func (this *ResourceTypeSpec) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ResourceTypeSpec

func (*ResourceTypeSpec) ProtoMessage added in v0.5.1

func (*ResourceTypeSpec) ProtoMessage()

func (*ResourceTypeSpec) ProtoReflect added in v0.5.1

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

func (*ResourceTypeSpec) Reset added in v0.5.1

func (x *ResourceTypeSpec) Reset()

func (*ResourceTypeSpec) String added in v0.5.1

func (x *ResourceTypeSpec) String() string

func (*ResourceTypeSpec) UnmarshalBinary added in v0.5.1

func (msg *ResourceTypeSpec) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*ResourceTypeSpec) UnmarshalJSON added in v0.5.1

func (this *ResourceTypeSpec) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ResourceTypeSpec

type Scope added in v0.5.1

type Scope int32
const (
	// buf:lint:ignore ENUM_ZERO_VALUE_SUFFIX
	Scope_SCOPE_UNDEFINED Scope = 0
	Scope_SCOPE_CLUSTER   Scope = 1
	Scope_SCOPE_PARTITION Scope = 2
	Scope_SCOPE_NAMESPACE Scope = 3
)

func (Scope) Descriptor added in v0.5.1

func (Scope) Descriptor() protoreflect.EnumDescriptor

func (Scope) Enum added in v0.5.1

func (x Scope) Enum() *Scope

func (Scope) EnumDescriptor deprecated added in v0.5.1

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

Deprecated: Use Scope.Descriptor instead.

func (Scope) Number added in v0.5.1

func (x Scope) Number() protoreflect.EnumNumber

func (Scope) String added in v0.5.1

func (x Scope) String() string

func (Scope) Type added in v0.5.1

func (Scope) Type() protoreflect.EnumType

type Status

type Status struct {

	// ObservedGeneration identifies which generation of a resource this status
	// related to. It can be used to determine whether the current generation of
	// a resource has been reconciled.
	ObservedGeneration string `protobuf:"bytes,1,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"`
	// Conditions contains a set of discreet observations about the resource in
	// relation to the current state of the system (e.g. it is semantically valid).
	Conditions []*Condition `protobuf:"bytes,2,rep,name=conditions,proto3" json:"conditions,omitempty"`
	// UpdatedAt is the time at which the status was last written.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Status is used by controllers to communicate the result of attempting to reconcile and apply a resource (e.g. surface semantic validation errors) with users and other controllers.

func (*Status) DeepCopy added in v0.5.1

func (in *Status) DeepCopy() *Status

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Status. Required by controller-gen.

func (*Status) DeepCopyInterface added in v0.5.1

func (in *Status) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Status. Required by controller-gen.

func (*Status) DeepCopyInto added in v0.5.1

func (in *Status) DeepCopyInto(out *Status)

DeepCopyInto supports using Status within kubernetes types, where deepcopy-gen is used.

func (*Status) Descriptor deprecated

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetConditions

func (x *Status) GetConditions() []*Condition

func (*Status) GetObservedGeneration

func (x *Status) GetObservedGeneration() string

func (*Status) GetUpdatedAt

func (x *Status) GetUpdatedAt() *timestamppb.Timestamp

func (*Status) MarshalBinary

func (msg *Status) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*Status) MarshalJSON added in v0.5.1

func (this *Status) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Status

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) ProtoReflect

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

func (*Status) Reset

func (x *Status) Reset()

func (*Status) String

func (x *Status) String() string

func (*Status) UnmarshalBinary

func (msg *Status) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*Status) UnmarshalJSON added in v0.5.1

func (this *Status) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Status

type Tenancy

type Tenancy struct {

	// Partition is the topmost administrative boundary within a cluster.
	// https://developer.hashicorp.com/consul/docs/enterprise/admin-partitions
	//
	// When using the List and WatchList endpoints, provide the wildcard value "*"
	// to list resources across all partitions.
	Partition string `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	// Namespace further isolates resources within a partition.
	// https://developer.hashicorp.com/consul/docs/enterprise/namespaces
	//
	// When using the List and WatchList endpoints, provide the wildcard value "*"
	// to list resources across all namespaces.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

Tenancy describes the tenancy units in which the resource resides.

func (*Tenancy) DeepCopy added in v0.5.1

func (in *Tenancy) DeepCopy() *Tenancy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Tenancy. Required by controller-gen.

func (*Tenancy) DeepCopyInterface added in v0.5.1

func (in *Tenancy) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Tenancy. Required by controller-gen.

func (*Tenancy) DeepCopyInto added in v0.5.1

func (in *Tenancy) DeepCopyInto(out *Tenancy)

DeepCopyInto supports using Tenancy within kubernetes types, where deepcopy-gen is used.

func (*Tenancy) Descriptor deprecated

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

Deprecated: Use Tenancy.ProtoReflect.Descriptor instead.

func (*Tenancy) GetNamespace

func (x *Tenancy) GetNamespace() string

func (*Tenancy) GetPartition

func (x *Tenancy) GetPartition() string

func (*Tenancy) MarshalBinary

func (msg *Tenancy) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*Tenancy) MarshalJSON added in v0.5.1

func (this *Tenancy) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Tenancy

func (*Tenancy) ProtoMessage

func (*Tenancy) ProtoMessage()

func (*Tenancy) ProtoReflect

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

func (*Tenancy) Reset

func (x *Tenancy) Reset()

func (*Tenancy) String

func (x *Tenancy) String() string

func (*Tenancy) UnmarshalBinary

func (msg *Tenancy) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*Tenancy) UnmarshalJSON added in v0.5.1

func (this *Tenancy) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Tenancy

type Tombstone

type Tombstone struct {

	// Owner resource identifier.
	Owner *ID `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

Tombstone represents a promise to delete all of a resource's immediately owned (child) resources, if any.

func (*Tombstone) DeepCopy added in v0.5.1

func (in *Tombstone) DeepCopy() *Tombstone

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Tombstone. Required by controller-gen.

func (*Tombstone) DeepCopyInterface added in v0.5.1

func (in *Tombstone) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Tombstone. Required by controller-gen.

func (*Tombstone) DeepCopyInto added in v0.5.1

func (in *Tombstone) DeepCopyInto(out *Tombstone)

DeepCopyInto supports using Tombstone within kubernetes types, where deepcopy-gen is used.

func (*Tombstone) Descriptor deprecated

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

Deprecated: Use Tombstone.ProtoReflect.Descriptor instead.

func (*Tombstone) GetOwner

func (x *Tombstone) GetOwner() *ID

func (*Tombstone) MarshalBinary

func (msg *Tombstone) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*Tombstone) MarshalJSON added in v0.5.1

func (this *Tombstone) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Tombstone

func (*Tombstone) ProtoMessage

func (*Tombstone) ProtoMessage()

func (*Tombstone) ProtoReflect

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

func (*Tombstone) Reset

func (x *Tombstone) Reset()

func (*Tombstone) String

func (x *Tombstone) String() string

func (*Tombstone) UnmarshalBinary

func (msg *Tombstone) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*Tombstone) UnmarshalJSON added in v0.5.1

func (this *Tombstone) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Tombstone

type Type

type Type struct {

	// Group describes the area of functionality to which this resource type
	// relates (e.g. "catalog", "authorization").
	Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// GroupVersion is incremented when sweeping or backward-incompatible changes
	// are made to the group's resource types.
	GroupVersion string `protobuf:"bytes,2,opt,name=group_version,json=groupVersion,proto3" json:"group_version,omitempty"`
	// Kind identifies the specific resource type within the group.
	Kind string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

Type describes a resource's type. It follows the GVK (Group Version Kind) [pattern](https://book.kubebuilder.io/cronjob-tutorial/gvks.html) established by Kubernetes.

func (*Type) DeepCopy added in v0.5.1

func (in *Type) DeepCopy() *Type

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Type. Required by controller-gen.

func (*Type) DeepCopyInterface added in v0.5.1

func (in *Type) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Type. Required by controller-gen.

func (*Type) DeepCopyInto added in v0.5.1

func (in *Type) DeepCopyInto(out *Type)

DeepCopyInto supports using Type within kubernetes types, where deepcopy-gen is used.

func (*Type) Descriptor deprecated

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

Deprecated: Use Type.ProtoReflect.Descriptor instead.

func (*Type) GetGroup

func (x *Type) GetGroup() string

func (*Type) GetGroupVersion

func (x *Type) GetGroupVersion() string

func (*Type) GetKind

func (x *Type) GetKind() string

func (*Type) MarshalBinary

func (msg *Type) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*Type) MarshalJSON added in v0.5.1

func (this *Type) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Type

func (*Type) ProtoMessage

func (*Type) ProtoMessage()

func (*Type) ProtoReflect

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

func (*Type) Reset

func (x *Type) Reset()

func (*Type) String

func (x *Type) String() string

func (*Type) UnmarshalBinary

func (msg *Type) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*Type) UnmarshalJSON added in v0.5.1

func (this *Type) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Type

type UnimplementedResourceServiceServer

type UnimplementedResourceServiceServer struct {
}

UnimplementedResourceServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedResourceServiceServer) Delete

func (UnimplementedResourceServiceServer) List

func (UnimplementedResourceServiceServer) ListByOwner

func (UnimplementedResourceServiceServer) MutateAndValidate added in v0.6.0

func (UnimplementedResourceServiceServer) Read

func (UnimplementedResourceServiceServer) WatchList

func (UnimplementedResourceServiceServer) Write

func (UnimplementedResourceServiceServer) WriteStatus

type UnsafeResourceServiceServer

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

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

type WatchEvent

type WatchEvent struct {

	// Types that are assignable to Event:
	//
	//	*WatchEvent_Upsert_
	//	*WatchEvent_Delete_
	//	*WatchEvent_EndOfSnapshot_
	Event isWatchEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

WatchEvent is emitted on the WatchList stream when a resource changes.

func (*WatchEvent) DeepCopy added in v0.5.1

func (in *WatchEvent) DeepCopy() *WatchEvent

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WatchEvent. Required by controller-gen.

func (*WatchEvent) DeepCopyInterface added in v0.5.1

func (in *WatchEvent) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WatchEvent. Required by controller-gen.

func (*WatchEvent) DeepCopyInto added in v0.5.1

func (in *WatchEvent) DeepCopyInto(out *WatchEvent)

DeepCopyInto supports using WatchEvent within kubernetes types, where deepcopy-gen is used.

func (*WatchEvent) Descriptor deprecated

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

Deprecated: Use WatchEvent.ProtoReflect.Descriptor instead.

func (*WatchEvent) GetDelete added in v0.6.0

func (x *WatchEvent) GetDelete() *WatchEvent_Delete

func (*WatchEvent) GetEndOfSnapshot added in v0.6.0

func (x *WatchEvent) GetEndOfSnapshot() *WatchEvent_EndOfSnapshot

func (*WatchEvent) GetEvent added in v0.6.0

func (m *WatchEvent) GetEvent() isWatchEvent_Event

func (*WatchEvent) GetUpsert added in v0.6.0

func (x *WatchEvent) GetUpsert() *WatchEvent_Upsert

func (*WatchEvent) MarshalBinary

func (msg *WatchEvent) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WatchEvent) MarshalJSON added in v0.5.1

func (this *WatchEvent) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WatchEvent

func (*WatchEvent) ProtoMessage

func (*WatchEvent) ProtoMessage()

func (*WatchEvent) ProtoReflect

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

func (*WatchEvent) Reset

func (x *WatchEvent) Reset()

func (*WatchEvent) String

func (x *WatchEvent) String() string

func (*WatchEvent) UnmarshalBinary

func (msg *WatchEvent) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WatchEvent) UnmarshalJSON added in v0.5.1

func (this *WatchEvent) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WatchEvent

type WatchEvent_Delete added in v0.6.0

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

Delete indicates that the resource was deleted.

func (*WatchEvent_Delete) DeepCopy added in v0.6.0

func (in *WatchEvent_Delete) DeepCopy() *WatchEvent_Delete

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WatchEvent_Delete. Required by controller-gen.

func (*WatchEvent_Delete) DeepCopyInterface added in v0.6.0

func (in *WatchEvent_Delete) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WatchEvent_Delete. Required by controller-gen.

func (*WatchEvent_Delete) DeepCopyInto added in v0.6.0

func (in *WatchEvent_Delete) DeepCopyInto(out *WatchEvent_Delete)

DeepCopyInto supports using WatchEvent_Delete within kubernetes types, where deepcopy-gen is used.

func (*WatchEvent_Delete) Descriptor deprecated added in v0.6.0

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

Deprecated: Use WatchEvent_Delete.ProtoReflect.Descriptor instead.

func (*WatchEvent_Delete) GetResource added in v0.6.0

func (x *WatchEvent_Delete) GetResource() *Resource

func (*WatchEvent_Delete) MarshalBinary added in v0.6.0

func (msg *WatchEvent_Delete) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WatchEvent_Delete) MarshalJSON added in v0.6.0

func (this *WatchEvent_Delete) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WatchEvent_Delete

func (*WatchEvent_Delete) ProtoMessage added in v0.6.0

func (*WatchEvent_Delete) ProtoMessage()

func (*WatchEvent_Delete) ProtoReflect added in v0.6.0

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

func (*WatchEvent_Delete) Reset added in v0.6.0

func (x *WatchEvent_Delete) Reset()

func (*WatchEvent_Delete) String added in v0.6.0

func (x *WatchEvent_Delete) String() string

func (*WatchEvent_Delete) UnmarshalBinary added in v0.6.0

func (msg *WatchEvent_Delete) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WatchEvent_Delete) UnmarshalJSON added in v0.6.0

func (this *WatchEvent_Delete) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WatchEvent_Delete

type WatchEvent_Delete_ added in v0.6.0

type WatchEvent_Delete_ struct {
	Delete *WatchEvent_Delete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type WatchEvent_EndOfSnapshot added in v0.6.0

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

EndOfSnapshot is sent to indicate that the initial snapshot events have been sent and future events will modify that set.

func (*WatchEvent_EndOfSnapshot) DeepCopy added in v0.6.0

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WatchEvent_EndOfSnapshot. Required by controller-gen.

func (*WatchEvent_EndOfSnapshot) DeepCopyInterface added in v0.6.0

func (in *WatchEvent_EndOfSnapshot) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WatchEvent_EndOfSnapshot. Required by controller-gen.

func (*WatchEvent_EndOfSnapshot) DeepCopyInto added in v0.6.0

func (in *WatchEvent_EndOfSnapshot) DeepCopyInto(out *WatchEvent_EndOfSnapshot)

DeepCopyInto supports using WatchEvent_EndOfSnapshot within kubernetes types, where deepcopy-gen is used.

func (*WatchEvent_EndOfSnapshot) Descriptor deprecated added in v0.6.0

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

Deprecated: Use WatchEvent_EndOfSnapshot.ProtoReflect.Descriptor instead.

func (*WatchEvent_EndOfSnapshot) MarshalBinary added in v0.6.0

func (msg *WatchEvent_EndOfSnapshot) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WatchEvent_EndOfSnapshot) MarshalJSON added in v0.6.0

func (this *WatchEvent_EndOfSnapshot) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WatchEvent_EndOfSnapshot

func (*WatchEvent_EndOfSnapshot) ProtoMessage added in v0.6.0

func (*WatchEvent_EndOfSnapshot) ProtoMessage()

func (*WatchEvent_EndOfSnapshot) ProtoReflect added in v0.6.0

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

func (*WatchEvent_EndOfSnapshot) Reset added in v0.6.0

func (x *WatchEvent_EndOfSnapshot) Reset()

func (*WatchEvent_EndOfSnapshot) String added in v0.6.0

func (x *WatchEvent_EndOfSnapshot) String() string

func (*WatchEvent_EndOfSnapshot) UnmarshalBinary added in v0.6.0

func (msg *WatchEvent_EndOfSnapshot) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WatchEvent_EndOfSnapshot) UnmarshalJSON added in v0.6.0

func (this *WatchEvent_EndOfSnapshot) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WatchEvent_EndOfSnapshot

type WatchEvent_EndOfSnapshot_ added in v0.6.0

type WatchEvent_EndOfSnapshot_ struct {
	EndOfSnapshot *WatchEvent_EndOfSnapshot `protobuf:"bytes,3,opt,name=end_of_snapshot,json=endOfSnapshot,proto3,oneof"`
}

type WatchEvent_Upsert added in v0.6.0

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

Upsert indicates that the resource was written (i.e. created or updated). All events from the initial state-of-the-world will be upsert events.

func (*WatchEvent_Upsert) DeepCopy added in v0.6.0

func (in *WatchEvent_Upsert) DeepCopy() *WatchEvent_Upsert

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WatchEvent_Upsert. Required by controller-gen.

func (*WatchEvent_Upsert) DeepCopyInterface added in v0.6.0

func (in *WatchEvent_Upsert) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WatchEvent_Upsert. Required by controller-gen.

func (*WatchEvent_Upsert) DeepCopyInto added in v0.6.0

func (in *WatchEvent_Upsert) DeepCopyInto(out *WatchEvent_Upsert)

DeepCopyInto supports using WatchEvent_Upsert within kubernetes types, where deepcopy-gen is used.

func (*WatchEvent_Upsert) Descriptor deprecated added in v0.6.0

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

Deprecated: Use WatchEvent_Upsert.ProtoReflect.Descriptor instead.

func (*WatchEvent_Upsert) GetResource added in v0.6.0

func (x *WatchEvent_Upsert) GetResource() *Resource

func (*WatchEvent_Upsert) MarshalBinary added in v0.6.0

func (msg *WatchEvent_Upsert) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WatchEvent_Upsert) MarshalJSON added in v0.6.0

func (this *WatchEvent_Upsert) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WatchEvent_Upsert

func (*WatchEvent_Upsert) ProtoMessage added in v0.6.0

func (*WatchEvent_Upsert) ProtoMessage()

func (*WatchEvent_Upsert) ProtoReflect added in v0.6.0

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

func (*WatchEvent_Upsert) Reset added in v0.6.0

func (x *WatchEvent_Upsert) Reset()

func (*WatchEvent_Upsert) String added in v0.6.0

func (x *WatchEvent_Upsert) String() string

func (*WatchEvent_Upsert) UnmarshalBinary added in v0.6.0

func (msg *WatchEvent_Upsert) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WatchEvent_Upsert) UnmarshalJSON added in v0.6.0

func (this *WatchEvent_Upsert) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WatchEvent_Upsert

type WatchEvent_Upsert_ added in v0.6.0

type WatchEvent_Upsert_ struct {
	Upsert *WatchEvent_Upsert `protobuf:"bytes,1,opt,name=upsert,proto3,oneof"`
}

type WatchListRequest

type WatchListRequest struct {

	// Type of resource to watch.
	Type *Type `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Tenancy units in which to watch resources. To list resources in all units,
	// provide the wildcard "*" value.
	Tenancy *Tenancy `protobuf:"bytes,2,opt,name=tenancy,proto3" json:"tenancy,omitempty"`
	// NamePrefix filters the results to those with a name beginning with the
	// given prefix.
	NamePrefix string `protobuf:"bytes,3,opt,name=name_prefix,json=namePrefix,proto3" json:"name_prefix,omitempty"`
	// contains filtered or unexported fields
}

WatchListRequest contains the parameters to the WatchList endpoint.

func (*WatchListRequest) DeepCopy added in v0.5.1

func (in *WatchListRequest) DeepCopy() *WatchListRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WatchListRequest. Required by controller-gen.

func (*WatchListRequest) DeepCopyInterface added in v0.5.1

func (in *WatchListRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WatchListRequest. Required by controller-gen.

func (*WatchListRequest) DeepCopyInto added in v0.5.1

func (in *WatchListRequest) DeepCopyInto(out *WatchListRequest)

DeepCopyInto supports using WatchListRequest within kubernetes types, where deepcopy-gen is used.

func (*WatchListRequest) Descriptor deprecated

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

Deprecated: Use WatchListRequest.ProtoReflect.Descriptor instead.

func (*WatchListRequest) GetNamePrefix

func (x *WatchListRequest) GetNamePrefix() string

func (*WatchListRequest) GetTenancy

func (x *WatchListRequest) GetTenancy() *Tenancy

func (*WatchListRequest) GetType

func (x *WatchListRequest) GetType() *Type

func (*WatchListRequest) MarshalBinary

func (msg *WatchListRequest) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WatchListRequest) MarshalJSON added in v0.5.1

func (this *WatchListRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WatchListRequest

func (*WatchListRequest) ProtoMessage

func (*WatchListRequest) ProtoMessage()

func (*WatchListRequest) ProtoReflect

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

func (*WatchListRequest) Reset

func (x *WatchListRequest) Reset()

func (*WatchListRequest) String

func (x *WatchListRequest) String() string

func (*WatchListRequest) UnmarshalBinary

func (msg *WatchListRequest) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WatchListRequest) UnmarshalJSON added in v0.5.1

func (this *WatchListRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WatchListRequest

type WriteRequest

type WriteRequest struct {

	// Resource to write.
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

WriteRequest contains the parameters to the Write endpoint.

func (*WriteRequest) DeepCopy added in v0.5.1

func (in *WriteRequest) DeepCopy() *WriteRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WriteRequest. Required by controller-gen.

func (*WriteRequest) DeepCopyInterface added in v0.5.1

func (in *WriteRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WriteRequest. Required by controller-gen.

func (*WriteRequest) DeepCopyInto added in v0.5.1

func (in *WriteRequest) DeepCopyInto(out *WriteRequest)

DeepCopyInto supports using WriteRequest within kubernetes types, where deepcopy-gen is used.

func (*WriteRequest) Descriptor deprecated

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

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetResource

func (x *WriteRequest) GetResource() *Resource

func (*WriteRequest) MarshalBinary

func (msg *WriteRequest) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WriteRequest) MarshalJSON added in v0.5.1

func (this *WriteRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WriteRequest

func (*WriteRequest) ProtoMessage

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect

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

func (*WriteRequest) Reset

func (x *WriteRequest) Reset()

func (*WriteRequest) String

func (x *WriteRequest) String() string

func (*WriteRequest) UnmarshalBinary

func (msg *WriteRequest) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WriteRequest) UnmarshalJSON added in v0.5.1

func (this *WriteRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WriteRequest

type WriteResponse

type WriteResponse struct {

	// Resource that was written.
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

WriteResponse contains the results of calling the Write endpoint.

func (*WriteResponse) DeepCopy added in v0.5.1

func (in *WriteResponse) DeepCopy() *WriteResponse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WriteResponse. Required by controller-gen.

func (*WriteResponse) DeepCopyInterface added in v0.5.1

func (in *WriteResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WriteResponse. Required by controller-gen.

func (*WriteResponse) DeepCopyInto added in v0.5.1

func (in *WriteResponse) DeepCopyInto(out *WriteResponse)

DeepCopyInto supports using WriteResponse within kubernetes types, where deepcopy-gen is used.

func (*WriteResponse) Descriptor deprecated

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

Deprecated: Use WriteResponse.ProtoReflect.Descriptor instead.

func (*WriteResponse) GetResource

func (x *WriteResponse) GetResource() *Resource

func (*WriteResponse) MarshalBinary

func (msg *WriteResponse) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WriteResponse) MarshalJSON added in v0.5.1

func (this *WriteResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WriteResponse

func (*WriteResponse) ProtoMessage

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) ProtoReflect

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

func (*WriteResponse) Reset

func (x *WriteResponse) Reset()

func (*WriteResponse) String

func (x *WriteResponse) String() string

func (*WriteResponse) UnmarshalBinary

func (msg *WriteResponse) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WriteResponse) UnmarshalJSON added in v0.5.1

func (this *WriteResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WriteResponse

type WriteStatusRequest

type WriteStatusRequest struct {

	// ID of the resource to which the status will be written. Must contain a Uid.
	Id *ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Version may be provided to perform a CAS (Compare-And-Swap) update of the
	// status. If the given version doesn't match what is currently stored, an
	// Aborted error code will be returned.
	//
	// Note: in most cases, CAS status updates are not necessary because updates
	// are scoped to a specific status key and controllers are leader-elected so
	// there is no chance of a conflict.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Key identifies which status will be written. Generally, each controller
	// should write 1 status which it owns exclusively (i.e. no other controller
	// updates it).
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Status that will be written to the resource.
	Status *Status `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

WriteStatusRequest contains the parameters to the WriteStatus endpoint.

func (*WriteStatusRequest) DeepCopy added in v0.5.1

func (in *WriteStatusRequest) DeepCopy() *WriteStatusRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WriteStatusRequest. Required by controller-gen.

func (*WriteStatusRequest) DeepCopyInterface added in v0.5.1

func (in *WriteStatusRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WriteStatusRequest. Required by controller-gen.

func (*WriteStatusRequest) DeepCopyInto added in v0.5.1

func (in *WriteStatusRequest) DeepCopyInto(out *WriteStatusRequest)

DeepCopyInto supports using WriteStatusRequest within kubernetes types, where deepcopy-gen is used.

func (*WriteStatusRequest) Descriptor deprecated

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

Deprecated: Use WriteStatusRequest.ProtoReflect.Descriptor instead.

func (*WriteStatusRequest) GetId

func (x *WriteStatusRequest) GetId() *ID

func (*WriteStatusRequest) GetKey

func (x *WriteStatusRequest) GetKey() string

func (*WriteStatusRequest) GetStatus

func (x *WriteStatusRequest) GetStatus() *Status

func (*WriteStatusRequest) GetVersion

func (x *WriteStatusRequest) GetVersion() string

func (*WriteStatusRequest) MarshalBinary

func (msg *WriteStatusRequest) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WriteStatusRequest) MarshalJSON added in v0.5.1

func (this *WriteStatusRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WriteStatusRequest

func (*WriteStatusRequest) ProtoMessage

func (*WriteStatusRequest) ProtoMessage()

func (*WriteStatusRequest) ProtoReflect

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

func (*WriteStatusRequest) Reset

func (x *WriteStatusRequest) Reset()

func (*WriteStatusRequest) String

func (x *WriteStatusRequest) String() string

func (*WriteStatusRequest) UnmarshalBinary

func (msg *WriteStatusRequest) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WriteStatusRequest) UnmarshalJSON added in v0.5.1

func (this *WriteStatusRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WriteStatusRequest

type WriteStatusResponse

type WriteStatusResponse struct {

	// Resource to which the status was written.
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

WriteStatusResponse contains the results of calling the WriteStatus endpoint.

func (*WriteStatusResponse) DeepCopy added in v0.5.1

func (in *WriteStatusResponse) DeepCopy() *WriteStatusResponse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WriteStatusResponse. Required by controller-gen.

func (*WriteStatusResponse) DeepCopyInterface added in v0.5.1

func (in *WriteStatusResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WriteStatusResponse. Required by controller-gen.

func (*WriteStatusResponse) DeepCopyInto added in v0.5.1

func (in *WriteStatusResponse) DeepCopyInto(out *WriteStatusResponse)

DeepCopyInto supports using WriteStatusResponse within kubernetes types, where deepcopy-gen is used.

func (*WriteStatusResponse) Descriptor deprecated

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

Deprecated: Use WriteStatusResponse.ProtoReflect.Descriptor instead.

func (*WriteStatusResponse) GetResource

func (x *WriteStatusResponse) GetResource() *Resource

func (*WriteStatusResponse) MarshalBinary

func (msg *WriteStatusResponse) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WriteStatusResponse) MarshalJSON added in v0.5.1

func (this *WriteStatusResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WriteStatusResponse

func (*WriteStatusResponse) ProtoMessage

func (*WriteStatusResponse) ProtoMessage()

func (*WriteStatusResponse) ProtoReflect

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

func (*WriteStatusResponse) Reset

func (x *WriteStatusResponse) Reset()

func (*WriteStatusResponse) String

func (x *WriteStatusResponse) String() string

func (*WriteStatusResponse) UnmarshalBinary

func (msg *WriteStatusResponse) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WriteStatusResponse) UnmarshalJSON added in v0.5.1

func (this *WriteStatusResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WriteStatusResponse

Jump to

Keyboard shortcuts

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