pbpeering

package
v1.16.109 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2023 License: MPL-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PeeringState_name = map[int32]string{
		0: "UNDEFINED",
		1: "PENDING",
		2: "ESTABLISHING",
		3: "ACTIVE",
		4: "FAILING",
		5: "DELETING",
		6: "TERMINATED",
	}
	PeeringState_value = map[string]int32{
		"UNDEFINED":    0,
		"PENDING":      1,
		"ESTABLISHING": 2,
		"ACTIVE":       3,
		"FAILING":      4,
		"DELETING":     5,
		"TERMINATED":   6,
	}
)

Enum value maps for PeeringState.

View Source 
var File_private_pbpeering_peering_proto protoreflect.FileDescriptor
View Source 
var PeeringService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hashicorp.consul.internal.peering.PeeringService",
	HandlerType: (*PeeringServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GenerateToken",
			Handler:    _PeeringService_GenerateToken_Handler,
		},
		{
			MethodName: "Establish",
			Handler:    _PeeringService_Establish_Handler,
		},
		{
			MethodName: "PeeringRead",
			Handler:    _PeeringService_PeeringRead_Handler,
		},
		{
			MethodName: "PeeringList",
			Handler:    _PeeringService_PeeringList_Handler,
		},
		{
			MethodName: "PeeringDelete",
			Handler:    _PeeringService_PeeringDelete_Handler,
		},
		{
			MethodName: "PeeringWrite",
			Handler:    _PeeringService_PeeringWrite_Handler,
		},
		{
			MethodName: "TrustBundleListByService",
			Handler:    _PeeringService_TrustBundleListByService_Handler,
		},
		{
			MethodName: "TrustBundleRead",
			Handler:    _PeeringService_TrustBundleRead_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "private/pbpeering/peering.proto",
}

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

Functions

func EstablishRequestFromAPI 

func EstablishRequestFromAPI(t *api.PeeringEstablishRequest, s *EstablishRequest)

func EstablishRequestToAPI 

func EstablishRequestToAPI(s *EstablishRequest, t *api.PeeringEstablishRequest)

func EstablishResponseFromAPI 

func EstablishResponseFromAPI(t *api.PeeringEstablishResponse, s *EstablishResponse)

func EstablishResponseToAPI 

func EstablishResponseToAPI(s *EstablishResponse, t *api.PeeringEstablishResponse)

func GenerateTokenRequestFromAPI 

func GenerateTokenRequestFromAPI(t *api.PeeringGenerateTokenRequest, s *GenerateTokenRequest)

func GenerateTokenRequestToAPI 

func GenerateTokenRequestToAPI(s *GenerateTokenRequest, t *api.PeeringGenerateTokenRequest)

func GenerateTokenResponseFromAPI 

func GenerateTokenResponseFromAPI(t *api.PeeringGenerateTokenResponse, s *GenerateTokenResponse)

func GenerateTokenResponseToAPI 

func GenerateTokenResponseToAPI(s *GenerateTokenResponse, t *api.PeeringGenerateTokenResponse)

func LocalityFromAPI 

func LocalityFromAPI(l *api.Locality) *pbcommon.Locality

TODO: handle this with mog LocalityFromProto converts an API Locality to a protobuf Locality.

func LocalityFromStructs 

func LocalityFromStructs(l *structs.Locality) *pbcommon.Locality

TODO: handle this with mog LocalityFromStructs converts a struct Locality to a protobuf Locality.

func LocalityToAPI 

func LocalityToAPI(l *pbcommon.Locality) *api.Locality

TODO: handle this with mog LocalityToAPI converts a protobuf Locality to an API Locality.

func LocalityToStructs 

func LocalityToStructs(l *pbcommon.Locality) *structs.Locality

TODO: handle this with mog LocalityToStructs converts a protobuf Locality to a struct Locality.

func PeeringFromAPI 

func PeeringFromAPI(t *api.Peering, s *Peering)

func PeeringStateToAPI 

func PeeringStateToAPI(s PeeringState) api.PeeringState

enumcover:PeeringState

func PeeringToAPI 

func PeeringToAPI(s *Peering, t *api.Peering)

func RegisterPeeringServiceServer 

func RegisterPeeringServiceServer(s grpc.ServiceRegistrar, srv PeeringServiceServer)

func RemoteInfoFromAPI 

func RemoteInfoFromAPI(t *api.PeeringRemoteInfo, s *RemoteInfo)

func RemoteInfoToAPI 

func RemoteInfoToAPI(s *RemoteInfo, t *api.PeeringRemoteInfo)

func StreamStatusToAPI 

func StreamStatusToAPI(status *StreamStatus) api.PeeringStreamStatus

func TimePtrFromProto 

func TimePtrFromProto(s *timestamppb.Timestamp) *time.Time

func TimePtrToProto 

func TimePtrToProto(s *time.Time) *timestamppb.Timestamp

Types

type EstablishRequest 

type EstablishRequest struct {

	// Name of the remote peer.
	PeerName string `protobuf:"bytes,1,opt,name=PeerName,proto3" json:"PeerName,omitempty"`
	// The peering token returned from the peer's GenerateToken endpoint.
	PeeringToken string `protobuf:"bytes,2,opt,name=PeeringToken,proto3" json:"PeeringToken,omitempty"`
	// Partition is the local partition being peered.
	Partition string `protobuf:"bytes,3,opt,name=Partition,proto3" json:"Partition,omitempty"`
	// Meta is a mapping of some string value to any other string value
	Meta map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

mog annotation:

target=github.com/hernad/consul/api.PeeringEstablishRequest output=peering.gen.go name=API

func NewEstablishRequestFromAPI 

func NewEstablishRequestFromAPI(req *api.PeeringEstablishRequest) *EstablishRequest

convenience

func (*EstablishRequest) Descriptor deprecated 

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

Deprecated: Use EstablishRequest.ProtoReflect.Descriptor instead.

func (*EstablishRequest) GetMeta 

func (x *EstablishRequest) GetMeta() map[string]string

func (*EstablishRequest) GetPartition 

func (x *EstablishRequest) GetPartition() string

func (*EstablishRequest) GetPeerName 

func (x *EstablishRequest) GetPeerName() string

func (*EstablishRequest) GetPeeringToken 

func (x *EstablishRequest) GetPeeringToken() string

func (*EstablishRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*EstablishRequest) ProtoMessage 

func (*EstablishRequest) ProtoMessage()

func (*EstablishRequest) ProtoReflect 

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

func (*EstablishRequest) RequestDatacenter 

func (req *EstablishRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*EstablishRequest) Reset 

func (x *EstablishRequest) Reset()

func (*EstablishRequest) String 

func (x *EstablishRequest) String() string

func (*EstablishRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type EstablishResponse 

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

mog annotation:

target=github.com/hernad/consul/api.PeeringEstablishResponse output=peering.gen.go name=API

func (*EstablishResponse) Descriptor deprecated 

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

Deprecated: Use EstablishResponse.ProtoReflect.Descriptor instead.

func (*EstablishResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*EstablishResponse) ProtoMessage 

func (*EstablishResponse) ProtoMessage()

func (*EstablishResponse) ProtoReflect 

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

func (*EstablishResponse) Reset 

func (x *EstablishResponse) Reset()

func (*EstablishResponse) String 

func (x *EstablishResponse) String() string

func (*EstablishResponse) ToAPI 

func (resp *EstablishResponse) ToAPI() *api.PeeringEstablishResponse

TODO consider using mog for this

func (*EstablishResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type GenerateTokenRequest 

type GenerateTokenRequest struct {

	// Name of the remote peer.
	PeerName string `protobuf:"bytes,1,opt,name=PeerName,proto3" json:"PeerName,omitempty"`
	// Partition is the local partition being peered.
	Partition string `protobuf:"bytes,2,opt,name=Partition,proto3" json:"Partition,omitempty"`
	// Meta is a mapping of some string value to any other string value
	Meta map[string]string `` /* 149-byte string literal not displayed */
	// ServerExternalAddresses is a list of addresses to put into the generated token. This could be used to specify
	// load balancer(s) or external IPs to reach the servers from the dialing side, and will override any server
	// addresses obtained from the "consul" service.
	ServerExternalAddresses []string `protobuf:"bytes,6,rep,name=ServerExternalAddresses,proto3" json:"ServerExternalAddresses,omitempty"`
	// contains filtered or unexported fields
}

mog annotation:

target=github.com/hernad/consul/api.PeeringGenerateTokenRequest output=peering.gen.go name=API

func NewGenerateTokenRequestFromAPI 

func NewGenerateTokenRequestFromAPI(req *api.PeeringGenerateTokenRequest) *GenerateTokenRequest

convenience

func (*GenerateTokenRequest) Descriptor deprecated 

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

Deprecated: Use GenerateTokenRequest.ProtoReflect.Descriptor instead.

func (*GenerateTokenRequest) GetMeta 

func (x *GenerateTokenRequest) GetMeta() map[string]string

func (*GenerateTokenRequest) GetPartition 

func (x *GenerateTokenRequest) GetPartition() string

func (*GenerateTokenRequest) GetPeerName 

func (x *GenerateTokenRequest) GetPeerName() string

func (*GenerateTokenRequest) GetServerExternalAddresses 

func (x *GenerateTokenRequest) GetServerExternalAddresses() []string

func (*GenerateTokenRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*GenerateTokenRequest) PartitionOrDefault 

func (r *GenerateTokenRequest) PartitionOrDefault() string

func (*GenerateTokenRequest) ProtoMessage 

func (*GenerateTokenRequest) ProtoMessage()

func (*GenerateTokenRequest) ProtoReflect 

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

func (*GenerateTokenRequest) RequestDatacenter 

func (req *GenerateTokenRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*GenerateTokenRequest) Reset 

func (x *GenerateTokenRequest) Reset()

func (*GenerateTokenRequest) String 

func (x *GenerateTokenRequest) String() string

func (*GenerateTokenRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type GenerateTokenResponse 

type GenerateTokenResponse struct {

	// PeeringToken is an opaque string provided to the remote peer for it to complete
	// the peering initialization handshake.
	PeeringToken string `protobuf:"bytes,1,opt,name=PeeringToken,proto3" json:"PeeringToken,omitempty"`
	// contains filtered or unexported fields
}

mog annotation:

target=github.com/hernad/consul/api.PeeringGenerateTokenResponse output=peering.gen.go name=API

func (*GenerateTokenResponse) Descriptor deprecated 

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

Deprecated: Use GenerateTokenResponse.ProtoReflect.Descriptor instead.

func (*GenerateTokenResponse) GetPeeringToken 

func (x *GenerateTokenResponse) GetPeeringToken() string

func (*GenerateTokenResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*GenerateTokenResponse) ProtoMessage 

func (*GenerateTokenResponse) ProtoMessage()

func (*GenerateTokenResponse) ProtoReflect 

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

func (*GenerateTokenResponse) Reset 

func (x *GenerateTokenResponse) Reset()

func (*GenerateTokenResponse) String 

func (x *GenerateTokenResponse) String() string

func (*GenerateTokenResponse) ToAPI 

func (resp *GenerateTokenResponse) ToAPI() *api.PeeringGenerateTokenResponse

TODO consider using mog for this

func (*GenerateTokenResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type Peering 

type Peering struct {

	// ID is a datacenter-scoped UUID for the peering.
	// The ID is generated when a peering is first written to the state store.
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Name is the local alias for the peering relationship.
	Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	// Partition is the local partition connecting to the peer.
	Partition string `protobuf:"bytes,3,opt,name=Partition,proto3" json:"Partition,omitempty"`
	// DeletedAt is the time when the Peering was marked for deletion
	// This is nullable so that we can omit if empty when encoding in JSON
	// mog: func-to=TimePtrFromProto func-from=TimePtrToProto
	DeletedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=DeletedAt,proto3" json:"DeletedAt,omitempty"`
	// Meta is a mapping of some string value to any other string value
	Meta map[string]string `` /* 149-byte string literal not displayed */
	// State is one of the valid PeeringState values to represent the status of
	// peering relationship.
	//
	// mog: func-to=PeeringStateToAPI func-from=PeeringStateFromAPI
	State PeeringState `protobuf:"varint,6,opt,name=State,proto3,enum=hashicorp.consul.internal.peering.PeeringState" json:"State,omitempty"`
	// PeerID is the ID that our peer assigned to this peering.
	// This ID is to be used when dialing the peer, so that it can know who dialed it.
	PeerID string `protobuf:"bytes,7,opt,name=PeerID,proto3" json:"PeerID,omitempty"`
	// PeerCAPems contains all the CA certificates for the remote peer.
	PeerCAPems []string `protobuf:"bytes,8,rep,name=PeerCAPems,proto3" json:"PeerCAPems,omitempty"`
	// PeerServerName is the name of the remote server as it relates to TLS.
	PeerServerName string `protobuf:"bytes,9,opt,name=PeerServerName,proto3" json:"PeerServerName,omitempty"`
	// PeerServerAddresses contains all the the connection addresses for the remote peer.
	PeerServerAddresses []string `protobuf:"bytes,10,rep,name=PeerServerAddresses,proto3" json:"PeerServerAddresses,omitempty"`
	// StreamStatus contains information computed on read based on the state of the stream.
	//
	// mog: func-to=StreamStatusToAPI func-from=StreamStatusFromAPI
	StreamStatus *StreamStatus `protobuf:"bytes,13,opt,name=StreamStatus,proto3" json:"StreamStatus,omitempty"`
	// CreateIndex is the Raft index at which the Peering was created.
	// @gotags: bexpr:"-"
	CreateIndex uint64 `protobuf:"varint,11,opt,name=CreateIndex,proto3" json:"CreateIndex,omitempty" bexpr:"-"`
	// ModifyIndex is the latest Raft index at which the Peering. was modified.
	// @gotags: bexpr:"-"
	ModifyIndex uint64 `protobuf:"varint,12,opt,name=ModifyIndex,proto3" json:"ModifyIndex,omitempty" bexpr:"-"`
	// Remote contains metadata about the remote peer.
	Remote *RemoteInfo `protobuf:"bytes,17,opt,name=Remote,proto3" json:"Remote,omitempty"`
	// ManualServerAddresses provides a list of manually specified server addresses from the
	// user. If this is defined, then the automatic PeerServerAddresses are ignored.
	ManualServerAddresses []string `protobuf:"bytes,18,rep,name=ManualServerAddresses,proto3" json:"ManualServerAddresses,omitempty"`
	// contains filtered or unexported fields
}

Peering defines a peering relationship between two disparate Consul clusters

mog annotation:

target=github.com/hernad/consul/api.Peering output=peering.gen.go name=API

func (*Peering) Descriptor deprecated 

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

Deprecated: Use Peering.ProtoReflect.Descriptor instead.

func (*Peering) GetAddressesToDial 

func (p *Peering) GetAddressesToDial() []string

GetAddressesToDial returns the listing of addresses that should be dialed for the peering. It will ensure that manual addresses take precedence, if any are defined.

func (*Peering) GetCreateIndex 

func (x *Peering) GetCreateIndex() uint64

func (*Peering) GetDeletedAt 

func (x *Peering) GetDeletedAt() *timestamppb.Timestamp

func (*Peering) GetID 

func (x *Peering) GetID() string

func (*Peering) GetManualServerAddresses 

func (x *Peering) GetManualServerAddresses() []string

func (*Peering) GetMeta 

func (x *Peering) GetMeta() map[string]string

func (*Peering) GetModifyIndex 

func (x *Peering) GetModifyIndex() uint64

func (*Peering) GetName 

func (x *Peering) GetName() string

func (*Peering) GetPartition 

func (x *Peering) GetPartition() string

func (*Peering) GetPeerCAPems 

func (x *Peering) GetPeerCAPems() []string

func (*Peering) GetPeerID 

func (x *Peering) GetPeerID() string

func (*Peering) GetPeerServerAddresses 

func (x *Peering) GetPeerServerAddresses() []string

func (*Peering) GetPeerServerName 

func (x *Peering) GetPeerServerName() string

func (*Peering) GetRemote 

func (x *Peering) GetRemote() *RemoteInfo

func (*Peering) GetState 

func (x *Peering) GetState() PeeringState

func (*Peering) GetStreamStatus 

func (x *Peering) GetStreamStatus() *StreamStatus

func (*Peering) IsActive 

func (p *Peering) IsActive() bool

func (*Peering) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*Peering) PartitionOrDefault 

func (p *Peering) PartitionOrDefault() string

func (*Peering) ProtoMessage 

func (*Peering) ProtoMessage()

func (*Peering) ProtoReflect 

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

func (*Peering) Reset 

func (x *Peering) Reset()

func (*Peering) ShouldDial 

func (p *Peering) ShouldDial() bool

ShouldDial returns true when the peering was stored via the peering initiation endpoint, AND the peering is not marked as terminated by our peer. If we generated a token for this peer we did not store our server addresses under PeerServerAddresses or ManualServerAddresses. These server addresses are for dialing, and only the peer initiating the peering will do the dialing.

func (*Peering) String 

func (x *Peering) String() string

func (*Peering) TLSDialOption 

func (p *Peering) TLSDialOption() (grpc.DialOption, error)

TLSDialOption returns the gRPC DialOption to secure the transport if CAPems ara available. If no CAPems were provided in the peering token then the WithInsecure dial option is returned.

func (*Peering) ToAPI 

func (p *Peering) ToAPI() *api.Peering

func (*Peering) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringDeleteRequest 

type PeeringDeleteRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Partition string `protobuf:"bytes,2,opt,name=Partition,proto3" json:"Partition,omitempty"`
	// contains filtered or unexported fields
}

func (*PeeringDeleteRequest) Descriptor deprecated 

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

Deprecated: Use PeeringDeleteRequest.ProtoReflect.Descriptor instead.

func (*PeeringDeleteRequest) GetName 

func (x *PeeringDeleteRequest) GetName() string

func (*PeeringDeleteRequest) GetPartition 

func (x *PeeringDeleteRequest) GetPartition() string

func (*PeeringDeleteRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringDeleteRequest) ProtoMessage 

func (*PeeringDeleteRequest) ProtoMessage()

func (*PeeringDeleteRequest) ProtoReflect 

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

func (*PeeringDeleteRequest) RequestDatacenter 

func (req *PeeringDeleteRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*PeeringDeleteRequest) Reset 

func (x *PeeringDeleteRequest) Reset()

func (*PeeringDeleteRequest) String 

func (x *PeeringDeleteRequest) String() string

func (*PeeringDeleteRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringDeleteResponse 

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

func (*PeeringDeleteResponse) Descriptor deprecated 

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

Deprecated: Use PeeringDeleteResponse.ProtoReflect.Descriptor instead.

func (*PeeringDeleteResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringDeleteResponse) ProtoMessage 

func (*PeeringDeleteResponse) ProtoMessage()

func (*PeeringDeleteResponse) ProtoReflect 

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

func (*PeeringDeleteResponse) Reset 

func (x *PeeringDeleteResponse) Reset()

func (*PeeringDeleteResponse) String 

func (x *PeeringDeleteResponse) String() string

func (*PeeringDeleteResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringListRequest 

type PeeringListRequest struct {
	Partition string `protobuf:"bytes,1,opt,name=Partition,proto3" json:"Partition,omitempty"`
	// contains filtered or unexported fields
}

func (*PeeringListRequest) Descriptor deprecated 

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

Deprecated: Use PeeringListRequest.ProtoReflect.Descriptor instead.

func (*PeeringListRequest) GetPartition 

func (x *PeeringListRequest) GetPartition() string

func (*PeeringListRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringListRequest) ProtoMessage 

func (*PeeringListRequest) ProtoMessage()

func (*PeeringListRequest) ProtoReflect 

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

func (*PeeringListRequest) RequestDatacenter 

func (req *PeeringListRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*PeeringListRequest) Reset 

func (x *PeeringListRequest) Reset()

func (*PeeringListRequest) String 

func (x *PeeringListRequest) String() string

func (*PeeringListRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringListResponse 

type PeeringListResponse struct {
	Peerings       []*Peering `protobuf:"bytes,1,rep,name=Peerings,proto3" json:"Peerings,omitempty"`
	OBSOLETE_Index uint64     `protobuf:"varint,2,opt,name=OBSOLETE_Index,json=OBSOLETEIndex,proto3" json:"OBSOLETE_Index,omitempty"` // Deprecated in favor of gRPC metadata
	// contains filtered or unexported fields
}

func (*PeeringListResponse) Descriptor deprecated 

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

Deprecated: Use PeeringListResponse.ProtoReflect.Descriptor instead.

func (*PeeringListResponse) GetOBSOLETE_Index 

func (x *PeeringListResponse) GetOBSOLETE_Index() uint64

func (*PeeringListResponse) GetPeerings 

func (x *PeeringListResponse) GetPeerings() []*Peering

func (*PeeringListResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringListResponse) ProtoMessage 

func (*PeeringListResponse) ProtoMessage()

func (*PeeringListResponse) ProtoReflect 

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

func (*PeeringListResponse) Reset 

func (x *PeeringListResponse) Reset()

func (*PeeringListResponse) String 

func (x *PeeringListResponse) String() string

func (*PeeringListResponse) ToAPI 

func (resp *PeeringListResponse) ToAPI() []*api.Peering

TODO consider using mog for this

func (*PeeringListResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringReadRequest 

type PeeringReadRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Partition string `protobuf:"bytes,2,opt,name=Partition,proto3" json:"Partition,omitempty"`
	// contains filtered or unexported fields
}

func (*PeeringReadRequest) Descriptor deprecated 

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

Deprecated: Use PeeringReadRequest.ProtoReflect.Descriptor instead.

func (*PeeringReadRequest) GetName 

func (x *PeeringReadRequest) GetName() string

func (*PeeringReadRequest) GetPartition 

func (x *PeeringReadRequest) GetPartition() string

func (*PeeringReadRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringReadRequest) ProtoMessage 

func (*PeeringReadRequest) ProtoMessage()

func (*PeeringReadRequest) ProtoReflect 

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

func (*PeeringReadRequest) RequestDatacenter 

func (req *PeeringReadRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*PeeringReadRequest) Reset 

func (x *PeeringReadRequest) Reset()

func (*PeeringReadRequest) String 

func (x *PeeringReadRequest) String() string

func (*PeeringReadRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringReadResponse 

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

func (*PeeringReadResponse) Descriptor deprecated 

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

Deprecated: Use PeeringReadResponse.ProtoReflect.Descriptor instead.

func (*PeeringReadResponse) GetPeering 

func (x *PeeringReadResponse) GetPeering() *Peering

func (*PeeringReadResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringReadResponse) ProtoMessage 

func (*PeeringReadResponse) ProtoMessage()

func (*PeeringReadResponse) ProtoReflect 

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

func (*PeeringReadResponse) Reset 

func (x *PeeringReadResponse) Reset()

func (*PeeringReadResponse) String 

func (x *PeeringReadResponse) String() string

func (*PeeringReadResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringSecrets 

type PeeringSecrets struct {

	// PeerID is the local UUID of the peering this secret was generated for.
	PeerID        string                        `protobuf:"bytes,1,opt,name=PeerID,proto3" json:"PeerID,omitempty"`
	Establishment *PeeringSecrets_Establishment `protobuf:"bytes,2,opt,name=establishment,proto3" json:"establishment,omitempty"`
	Stream        *PeeringSecrets_Stream        `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

PeeringSecrets defines a secret used for authenticating/authorizing peer clusters.

func (*PeeringSecrets) Descriptor deprecated 

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

Deprecated: Use PeeringSecrets.ProtoReflect.Descriptor instead.

func (*PeeringSecrets) GetEstablishment 

func (x *PeeringSecrets) GetEstablishment() *PeeringSecrets_Establishment

func (*PeeringSecrets) GetPeerID 

func (x *PeeringSecrets) GetPeerID() string

func (*PeeringSecrets) GetStream 

func (x *PeeringSecrets) GetStream() *PeeringSecrets_Stream

func (*PeeringSecrets) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringSecrets) ProtoMessage 

func (*PeeringSecrets) ProtoMessage()

func (*PeeringSecrets) ProtoReflect 

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

func (*PeeringSecrets) Reset 

func (x *PeeringSecrets) Reset()

func (*PeeringSecrets) String 

func (x *PeeringSecrets) String() string

func (*PeeringSecrets) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringSecrets_Establishment 

type PeeringSecrets_Establishment struct {

	// SecretID is the one-time-use peering establishment secret.
	SecretID string `protobuf:"bytes,1,opt,name=SecretID,proto3" json:"SecretID,omitempty"`
	// contains filtered or unexported fields
}

func (*PeeringSecrets_Establishment) Descriptor deprecated 

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

Deprecated: Use PeeringSecrets_Establishment.ProtoReflect.Descriptor instead.

func (*PeeringSecrets_Establishment) GetSecretID 

func (x *PeeringSecrets_Establishment) GetSecretID() string

func (*PeeringSecrets_Establishment) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringSecrets_Establishment) ProtoMessage 

func (*PeeringSecrets_Establishment) ProtoMessage()

func (*PeeringSecrets_Establishment) ProtoReflect 

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

func (*PeeringSecrets_Establishment) Reset 

func (x *PeeringSecrets_Establishment) Reset()

func (*PeeringSecrets_Establishment) String 

func (x *PeeringSecrets_Establishment) String() string

func (*PeeringSecrets_Establishment) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringSecrets_Stream 

type PeeringSecrets_Stream struct {

	// ActiveSecretID is the active UUID-v4 secret being used for authorization at
	// the peering stream.
	ActiveSecretID string `protobuf:"bytes,1,opt,name=ActiveSecretID,proto3" json:"ActiveSecretID,omitempty"`
	// PendingSecretID is a UUID-v4 secret introduced during secret rotation.
	// When a peering is established or re-established, both the active secret and
	// pending secret are considered valid. However, once the dialing peer uses
	// the pending secret then it transitions to active and the previously active
	// secret is discarded.
	//
	// Pending secret IDs are only valid for long-lived stream secrets.
	// Only one establishment secret can exist for a peer at a time since they
	// are designed for one-time use.
	PendingSecretID string `protobuf:"bytes,2,opt,name=PendingSecretID,proto3" json:"PendingSecretID,omitempty"`
	// contains filtered or unexported fields
}

func (*PeeringSecrets_Stream) Descriptor deprecated 

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

Deprecated: Use PeeringSecrets_Stream.ProtoReflect.Descriptor instead.

func (*PeeringSecrets_Stream) GetActiveSecretID 

func (x *PeeringSecrets_Stream) GetActiveSecretID() string

func (*PeeringSecrets_Stream) GetPendingSecretID 

func (x *PeeringSecrets_Stream) GetPendingSecretID() string

func (*PeeringSecrets_Stream) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringSecrets_Stream) ProtoMessage 

func (*PeeringSecrets_Stream) ProtoMessage()

func (*PeeringSecrets_Stream) ProtoReflect 

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

func (*PeeringSecrets_Stream) Reset 

func (x *PeeringSecrets_Stream) Reset()

func (*PeeringSecrets_Stream) String 

func (x *PeeringSecrets_Stream) String() string

func (*PeeringSecrets_Stream) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringServerAddresses 

type PeeringServerAddresses struct {
	Addresses []string `protobuf:"bytes,1,rep,name=Addresses,proto3" json:"Addresses,omitempty"`
	// contains filtered or unexported fields
}

PeeringServerAddresses contains the latest snapshot of all known server addresses for a peer.

func (*PeeringServerAddresses) Descriptor deprecated 

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

Deprecated: Use PeeringServerAddresses.ProtoReflect.Descriptor instead.

func (*PeeringServerAddresses) GetAddresses 

func (x *PeeringServerAddresses) GetAddresses() []string

func (*PeeringServerAddresses) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringServerAddresses) ProtoMessage 

func (*PeeringServerAddresses) ProtoMessage()

func (*PeeringServerAddresses) ProtoReflect 

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

func (*PeeringServerAddresses) Reset 

func (x *PeeringServerAddresses) Reset()

func (*PeeringServerAddresses) String 

func (x *PeeringServerAddresses) String() string

func (*PeeringServerAddresses) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringServiceClient 

type PeeringServiceClient interface {
	GenerateToken(ctx context.Context, in *GenerateTokenRequest, opts ...grpc.CallOption) (*GenerateTokenResponse, error)
	Establish(ctx context.Context, in *EstablishRequest, opts ...grpc.CallOption) (*EstablishResponse, error)
	PeeringRead(ctx context.Context, in *PeeringReadRequest, opts ...grpc.CallOption) (*PeeringReadResponse, error)
	PeeringList(ctx context.Context, in *PeeringListRequest, opts ...grpc.CallOption) (*PeeringListResponse, error)
	PeeringDelete(ctx context.Context, in *PeeringDeleteRequest, opts ...grpc.CallOption) (*PeeringDeleteResponse, error)
	// TODO(peering): As of writing, this method is only used in tests to set up Peerings in the state store.
	// Consider removing if we can find another way to populate state store in peering_endpoint_test.go
	PeeringWrite(ctx context.Context, in *PeeringWriteRequest, opts ...grpc.CallOption) (*PeeringWriteResponse, error)
	// TODO(peering): Rename this to PeeredServiceRoots? or something like that?
	TrustBundleListByService(ctx context.Context, in *TrustBundleListByServiceRequest, opts ...grpc.CallOption) (*TrustBundleListByServiceResponse, error)
	TrustBundleRead(ctx context.Context, in *TrustBundleReadRequest, opts ...grpc.CallOption) (*TrustBundleReadResponse, error)
}

PeeringServiceClient is the client API for PeeringService 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 NewPeeringServiceClient 

func NewPeeringServiceClient(cc grpc.ClientConnInterface) PeeringServiceClient

type PeeringServiceServer 

type PeeringServiceServer interface {
	GenerateToken(context.Context, *GenerateTokenRequest) (*GenerateTokenResponse, error)
	Establish(context.Context, *EstablishRequest) (*EstablishResponse, error)
	PeeringRead(context.Context, *PeeringReadRequest) (*PeeringReadResponse, error)
	PeeringList(context.Context, *PeeringListRequest) (*PeeringListResponse, error)
	PeeringDelete(context.Context, *PeeringDeleteRequest) (*PeeringDeleteResponse, error)
	// TODO(peering): As of writing, this method is only used in tests to set up Peerings in the state store.
	// Consider removing if we can find another way to populate state store in peering_endpoint_test.go
	PeeringWrite(context.Context, *PeeringWriteRequest) (*PeeringWriteResponse, error)
	// TODO(peering): Rename this to PeeredServiceRoots? or something like that?
	TrustBundleListByService(context.Context, *TrustBundleListByServiceRequest) (*TrustBundleListByServiceResponse, error)
	TrustBundleRead(context.Context, *TrustBundleReadRequest) (*TrustBundleReadResponse, error)
}

PeeringServiceServer is the server API for PeeringService service. All implementations should embed UnimplementedPeeringServiceServer for forward compatibility

type PeeringState 

type PeeringState int32

PeeringState enumerates all the states a peering can be in. 

const (
	// Undefined represents an unset value for PeeringState during
	// writes.
	PeeringState_UNDEFINED PeeringState = 0
	// Pending means the peering was created by generating a peering token.
	// Peerings stay in a pending state until the peer uses the token to dial
	// the local cluster.
	PeeringState_PENDING PeeringState = 1
	// Establishing means the peering is being established from a peering token.
	// This is the initial state for dialing peers.
	PeeringState_ESTABLISHING PeeringState = 2
	// Active means that the peering connection is active and healthy.
	PeeringState_ACTIVE PeeringState = 3
	// Failing means the peering connection has been interrupted but has not yet
	// been terminated.
	PeeringState_FAILING PeeringState = 4
	// Deleting means a peering was marked for deletion and is in the process
	// of being deleted.
	PeeringState_DELETING PeeringState = 5
	// Terminated means the peering relationship has been removed.
	PeeringState_TERMINATED PeeringState = 6
)

func PeeringStateFromAPI 

func PeeringStateFromAPI(t api.PeeringState) PeeringState

enumcover:api.PeeringState

func (PeeringState) Descriptor 

func (PeeringState) Descriptor() protoreflect.EnumDescriptor

func (PeeringState) Enum 

func (x PeeringState) Enum() *PeeringState

func (PeeringState) EnumDescriptor deprecated 

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

Deprecated: Use PeeringState.Descriptor instead.

func (PeeringState) GoString 

func (x PeeringState) GoString() string

func (PeeringState) Number 

func (x PeeringState) Number() protoreflect.EnumNumber

func (PeeringState) String 

func (x PeeringState) String() string

func (PeeringState) Type 

func (PeeringState) Type() protoreflect.EnumType

type PeeringTerminateByIDRequest 

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

This is a purely internal type and does not require query metadata.

func (*PeeringTerminateByIDRequest) Descriptor deprecated 

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

Deprecated: Use PeeringTerminateByIDRequest.ProtoReflect.Descriptor instead.

func (*PeeringTerminateByIDRequest) GetID 

func (x *PeeringTerminateByIDRequest) GetID() string

func (*PeeringTerminateByIDRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringTerminateByIDRequest) ProtoMessage 

func (*PeeringTerminateByIDRequest) ProtoMessage()

func (*PeeringTerminateByIDRequest) ProtoReflect 

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

func (*PeeringTerminateByIDRequest) Reset 

func (x *PeeringTerminateByIDRequest) Reset()

func (*PeeringTerminateByIDRequest) String 

func (x *PeeringTerminateByIDRequest) String() string

func (*PeeringTerminateByIDRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringTerminateByIDResponse 

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

func (*PeeringTerminateByIDResponse) Descriptor deprecated 

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

Deprecated: Use PeeringTerminateByIDResponse.ProtoReflect.Descriptor instead.

func (*PeeringTerminateByIDResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringTerminateByIDResponse) ProtoMessage 

func (*PeeringTerminateByIDResponse) ProtoMessage()

func (*PeeringTerminateByIDResponse) ProtoReflect 

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

func (*PeeringTerminateByIDResponse) Reset 

func (x *PeeringTerminateByIDResponse) Reset()

func (*PeeringTerminateByIDResponse) String 

func (x *PeeringTerminateByIDResponse) String() string

func (*PeeringTerminateByIDResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringTrustBundle 

type PeeringTrustBundle struct {

	// TrustDomain is the domain for the bundle, example.com, foo.bar.gov for example. Note that this must not have a prefix such as "spiffe://".
	TrustDomain string `protobuf:"bytes,1,opt,name=TrustDomain,proto3" json:"TrustDomain,omitempty"`
	// PeerName associates the trust bundle with a peer.
	PeerName string `protobuf:"bytes,2,opt,name=PeerName,proto3" json:"PeerName,omitempty"`
	// Partition isolates the bundle from other trust bundles in separate local partitions.
	Partition string `protobuf:"bytes,3,opt,name=Partition,proto3" json:"Partition,omitempty"`
	// RootPEMs holds ASN.1 DER encoded X.509 certificate data for the trust bundle.
	RootPEMs []string `protobuf:"bytes,4,rep,name=RootPEMs,proto3" json:"RootPEMs,omitempty"`
	// ExportedPartition references the remote partition of the peer
	// which sent this trust bundle. Used for generating SpiffeIDs.
	ExportedPartition string `protobuf:"bytes,5,opt,name=ExportedPartition,proto3" json:"ExportedPartition,omitempty"`
	// CreateIndex is the Raft index at which the trust domain was created.
	// @gotags: bexpr:"-"
	CreateIndex uint64 `protobuf:"varint,6,opt,name=CreateIndex,proto3" json:"CreateIndex,omitempty" bexpr:"-"`
	// ModifyIndex is the latest Raft index at which the trust bundle was modified.
	// @gotags: bexpr:"-"
	ModifyIndex uint64 `protobuf:"varint,7,opt,name=ModifyIndex,proto3" json:"ModifyIndex,omitempty" bexpr:"-"`
	// contains filtered or unexported fields
}

PeeringTrustBundle holds the trust information for validating requests from a peer.

func (*PeeringTrustBundle) ConcatenatedRootPEMs 

func (b *PeeringTrustBundle) ConcatenatedRootPEMs() string

ConcatenatedRootPEMs concatenates and returns all PEM-encoded public certificates in a peer's trust bundle.

func (*PeeringTrustBundle) DeepCopy 

func (o *PeeringTrustBundle) DeepCopy() *PeeringTrustBundle

DeepCopy returns a copy of the PeeringTrustBundle that can be passed around without worrying about the receiver unsafely modifying it. It is used by the generated DeepCopy methods in proxycfg.

func (*PeeringTrustBundle) Descriptor deprecated 

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

Deprecated: Use PeeringTrustBundle.ProtoReflect.Descriptor instead.

func (*PeeringTrustBundle) GetCreateIndex 

func (x *PeeringTrustBundle) GetCreateIndex() uint64

func (*PeeringTrustBundle) GetExportedPartition 

func (x *PeeringTrustBundle) GetExportedPartition() string

func (*PeeringTrustBundle) GetModifyIndex 

func (x *PeeringTrustBundle) GetModifyIndex() uint64

func (*PeeringTrustBundle) GetPartition 

func (x *PeeringTrustBundle) GetPartition() string

func (*PeeringTrustBundle) GetPeerName 

func (x *PeeringTrustBundle) GetPeerName() string

func (*PeeringTrustBundle) GetRootPEMs 

func (x *PeeringTrustBundle) GetRootPEMs() []string

func (*PeeringTrustBundle) GetTrustDomain 

func (x *PeeringTrustBundle) GetTrustDomain() string

func (*PeeringTrustBundle) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringTrustBundle) PartitionOrDefault 

func (ptb *PeeringTrustBundle) PartitionOrDefault() string

func (*PeeringTrustBundle) ProtoMessage 

func (*PeeringTrustBundle) ProtoMessage()

func (*PeeringTrustBundle) ProtoReflect 

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

func (*PeeringTrustBundle) Reset 

func (x *PeeringTrustBundle) Reset()

func (*PeeringTrustBundle) String 

func (x *PeeringTrustBundle) String() string

func (*PeeringTrustBundle) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringTrustBundleDeleteRequest 

type PeeringTrustBundleDeleteRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Partition string `protobuf:"bytes,2,opt,name=Partition,proto3" json:"Partition,omitempty"`
	// contains filtered or unexported fields
}

func (*PeeringTrustBundleDeleteRequest) Descriptor deprecated 

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

Deprecated: Use PeeringTrustBundleDeleteRequest.ProtoReflect.Descriptor instead.

func (*PeeringTrustBundleDeleteRequest) GetName 

func (x *PeeringTrustBundleDeleteRequest) GetName() string

func (*PeeringTrustBundleDeleteRequest) GetPartition 

func (x *PeeringTrustBundleDeleteRequest) GetPartition() string

func (*PeeringTrustBundleDeleteRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringTrustBundleDeleteRequest) ProtoMessage 

func (*PeeringTrustBundleDeleteRequest) ProtoMessage()

func (*PeeringTrustBundleDeleteRequest) ProtoReflect 

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

func (*PeeringTrustBundleDeleteRequest) Reset 

func (x *PeeringTrustBundleDeleteRequest) Reset()

func (*PeeringTrustBundleDeleteRequest) String 

func (x *PeeringTrustBundleDeleteRequest) String() string

func (*PeeringTrustBundleDeleteRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringTrustBundleDeleteResponse 

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

func (*PeeringTrustBundleDeleteResponse) Descriptor deprecated 

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

Deprecated: Use PeeringTrustBundleDeleteResponse.ProtoReflect.Descriptor instead.

func (*PeeringTrustBundleDeleteResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringTrustBundleDeleteResponse) ProtoMessage 

func (*PeeringTrustBundleDeleteResponse) ProtoMessage()

func (*PeeringTrustBundleDeleteResponse) ProtoReflect 

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

func (*PeeringTrustBundleDeleteResponse) Reset 

func (x *PeeringTrustBundleDeleteResponse) Reset()

func (*PeeringTrustBundleDeleteResponse) String 

func (x *PeeringTrustBundleDeleteResponse) String() string

func (*PeeringTrustBundleDeleteResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringTrustBundleWriteRequest 

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

func (*PeeringTrustBundleWriteRequest) Descriptor deprecated 

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

Deprecated: Use PeeringTrustBundleWriteRequest.ProtoReflect.Descriptor instead.

func (*PeeringTrustBundleWriteRequest) GetPeeringTrustBundle 

func (x *PeeringTrustBundleWriteRequest) GetPeeringTrustBundle() *PeeringTrustBundle

func (*PeeringTrustBundleWriteRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringTrustBundleWriteRequest) ProtoMessage 

func (*PeeringTrustBundleWriteRequest) ProtoMessage()

func (*PeeringTrustBundleWriteRequest) ProtoReflect 

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

func (*PeeringTrustBundleWriteRequest) Reset 

func (x *PeeringTrustBundleWriteRequest) Reset()

func (*PeeringTrustBundleWriteRequest) String 

func (x *PeeringTrustBundleWriteRequest) String() string

func (*PeeringTrustBundleWriteRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringTrustBundleWriteResponse 

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

func (*PeeringTrustBundleWriteResponse) Descriptor deprecated 

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

Deprecated: Use PeeringTrustBundleWriteResponse.ProtoReflect.Descriptor instead.

func (*PeeringTrustBundleWriteResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringTrustBundleWriteResponse) ProtoMessage 

func (*PeeringTrustBundleWriteResponse) ProtoMessage()

func (*PeeringTrustBundleWriteResponse) ProtoReflect 

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

func (*PeeringTrustBundleWriteResponse) Reset 

func (x *PeeringTrustBundleWriteResponse) Reset()

func (*PeeringTrustBundleWriteResponse) String 

func (x *PeeringTrustBundleWriteResponse) String() string

func (*PeeringTrustBundleWriteResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringWriteRequest 

type PeeringWriteRequest struct {

	// Peering is the peering to write with the request.
	Peering *Peering `protobuf:"bytes,1,opt,name=Peering,proto3" json:"Peering,omitempty"`
	// SecretsWriteRequest contains the optional peering secrets to persist
	// with the peering. Peering secrets are not embedded in the peering
	// object to avoid leaking them.
	SecretsRequest *SecretsWriteRequest `protobuf:"bytes,2,opt,name=SecretsRequest,proto3" json:"SecretsRequest,omitempty"`
	Meta           map[string]string    `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PeeringWriteRequest) Descriptor deprecated 

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

Deprecated: Use PeeringWriteRequest.ProtoReflect.Descriptor instead.

func (*PeeringWriteRequest) GetMeta 

func (x *PeeringWriteRequest) GetMeta() map[string]string

func (*PeeringWriteRequest) GetPeering 

func (x *PeeringWriteRequest) GetPeering() *Peering

func (*PeeringWriteRequest) GetSecretsRequest 

func (x *PeeringWriteRequest) GetSecretsRequest() *SecretsWriteRequest

func (*PeeringWriteRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringWriteRequest) ProtoMessage 

func (*PeeringWriteRequest) ProtoMessage()

func (*PeeringWriteRequest) ProtoReflect 

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

func (*PeeringWriteRequest) RequestDatacenter 

func (req *PeeringWriteRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*PeeringWriteRequest) Reset 

func (x *PeeringWriteRequest) Reset()

func (*PeeringWriteRequest) String 

func (x *PeeringWriteRequest) String() string

func (*PeeringWriteRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PeeringWriteResponse 

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

TODO(peering): Consider returning Peering if we keep this endpoint around

func (*PeeringWriteResponse) Descriptor deprecated 

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

Deprecated: Use PeeringWriteResponse.ProtoReflect.Descriptor instead.

func (*PeeringWriteResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringWriteResponse) ProtoMessage 

func (*PeeringWriteResponse) ProtoMessage()

func (*PeeringWriteResponse) ProtoReflect 

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

func (*PeeringWriteResponse) Reset 

func (x *PeeringWriteResponse) Reset()

func (*PeeringWriteResponse) String 

func (x *PeeringWriteResponse) String() string

func (*PeeringWriteResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type RemoteInfo 

type RemoteInfo struct {

	// Partition is the remote peer's partition.
	Partition string `protobuf:"bytes,1,opt,name=Partition,proto3" json:"Partition,omitempty"`
	// Datacenter is the remote peer's datacenter.
	Datacenter string `protobuf:"bytes,2,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
	// Locality identifies where the peer is running.
	// mog: func-to=LocalityToAPI func-from=LocalityFromAPI
	Locality *pbcommon.Locality `protobuf:"bytes,3,opt,name=Locality,proto3" json:"Locality,omitempty"`
	// contains filtered or unexported fields
}

mog annotation:

target=github.com/hernad/consul/api.PeeringRemoteInfo output=peering.gen.go name=API

func (*RemoteInfo) Descriptor deprecated 

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

Deprecated: Use RemoteInfo.ProtoReflect.Descriptor instead.

func (*RemoteInfo) GetDatacenter 

func (x *RemoteInfo) GetDatacenter() string

func (*RemoteInfo) GetLocality 

func (x *RemoteInfo) GetLocality() *pbcommon.Locality

func (*RemoteInfo) GetPartition 

func (x *RemoteInfo) GetPartition() string

func (*RemoteInfo) IsEmpty 

func (r *RemoteInfo) IsEmpty() bool

func (*RemoteInfo) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*RemoteInfo) ProtoMessage 

func (*RemoteInfo) ProtoMessage()

func (*RemoteInfo) ProtoReflect 

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

func (*RemoteInfo) Reset 

func (x *RemoteInfo) Reset()

func (*RemoteInfo) String 

func (x *RemoteInfo) String() string

func (*RemoteInfo) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type SecretsWriteRequest 

type SecretsWriteRequest struct {

	// PeerID is the local UUID of the peering this request applies to.
	PeerID string `protobuf:"bytes,1,opt,name=PeerID,proto3" json:"PeerID,omitempty"`
	// Types that are assignable to Request:
	//
	//	*SecretsWriteRequest_GenerateToken
	//	*SecretsWriteRequest_ExchangeSecret
	//	*SecretsWriteRequest_PromotePending
	//	*SecretsWriteRequest_Establish
	Request isSecretsWriteRequest_Request `protobuf_oneof:"Request"`
	// contains filtered or unexported fields
}

SecretsWriteRequest encodes a request to write a peering secret as the result of some operation. Different operations, such as generating a peering token, lead to modifying the known secrets associated with a peering.

func (*SecretsWriteRequest) Descriptor deprecated 

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

Deprecated: Use SecretsWriteRequest.ProtoReflect.Descriptor instead.

func (*SecretsWriteRequest) GetEstablish 

func (x *SecretsWriteRequest) GetEstablish() *SecretsWriteRequest_EstablishRequest

func (*SecretsWriteRequest) GetExchangeSecret 

func (x *SecretsWriteRequest) GetExchangeSecret() *SecretsWriteRequest_ExchangeSecretRequest

func (*SecretsWriteRequest) GetGenerateToken 

func (x *SecretsWriteRequest) GetGenerateToken() *SecretsWriteRequest_GenerateTokenRequest

func (*SecretsWriteRequest) GetPeerID 

func (x *SecretsWriteRequest) GetPeerID() string

func (*SecretsWriteRequest) GetPromotePending 

func (x *SecretsWriteRequest) GetPromotePending() *SecretsWriteRequest_PromotePendingRequest

func (*SecretsWriteRequest) GetRequest 

func (m *SecretsWriteRequest) GetRequest() isSecretsWriteRequest_Request

func (*SecretsWriteRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*SecretsWriteRequest) ProtoMessage 

func (*SecretsWriteRequest) ProtoMessage()

func (*SecretsWriteRequest) ProtoReflect 

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

func (*SecretsWriteRequest) Reset 

func (x *SecretsWriteRequest) Reset()

func (*SecretsWriteRequest) String 

func (x *SecretsWriteRequest) String() string

func (*SecretsWriteRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*SecretsWriteRequest) Validate 

func (s *SecretsWriteRequest) Validate() error

Validate is a validation helper that checks whether a secret ID is embedded in the container type.

type SecretsWriteRequest_Establish 

type SecretsWriteRequest_Establish struct {
	Establish *SecretsWriteRequest_EstablishRequest `protobuf:"bytes,5,opt,name=establish,proto3,oneof"`
}

type SecretsWriteRequest_EstablishRequest 

type SecretsWriteRequest_EstablishRequest struct {

	// active_stream_secret is the proposed secret ID to store as the active stream
	// secret for this peering.
	ActiveStreamSecret string `protobuf:"bytes,1,opt,name=active_stream_secret,json=activeStreamSecret,proto3" json:"active_stream_secret,omitempty"`
	// contains filtered or unexported fields
}

EstablishRequest encodes a request to persist an active stream secret. It is triggered after a dialing peer exchanges their establishment secret for a long-lived active stream secret.

func (*SecretsWriteRequest_EstablishRequest) Descriptor deprecated 

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

Deprecated: Use SecretsWriteRequest_EstablishRequest.ProtoReflect.Descriptor instead.

func (*SecretsWriteRequest_EstablishRequest) GetActiveStreamSecret 

func (x *SecretsWriteRequest_EstablishRequest) GetActiveStreamSecret() string

func (*SecretsWriteRequest_EstablishRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*SecretsWriteRequest_EstablishRequest) ProtoMessage 

func (*SecretsWriteRequest_EstablishRequest) ProtoMessage()

func (*SecretsWriteRequest_EstablishRequest) ProtoReflect 

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

func (*SecretsWriteRequest_EstablishRequest) Reset 

func (x *SecretsWriteRequest_EstablishRequest) Reset()

func (*SecretsWriteRequest_EstablishRequest) String 

func (x *SecretsWriteRequest_EstablishRequest) String() string

func (*SecretsWriteRequest_EstablishRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type SecretsWriteRequest_ExchangeSecret 

type SecretsWriteRequest_ExchangeSecret struct {
	ExchangeSecret *SecretsWriteRequest_ExchangeSecretRequest `protobuf:"bytes,3,opt,name=exchange_secret,json=exchangeSecret,proto3,oneof"`
}

type SecretsWriteRequest_ExchangeSecretRequest 

type SecretsWriteRequest_ExchangeSecretRequest struct {

	// establishment_secret is the secret to exchange for the given pending stream secret.
	EstablishmentSecret string `protobuf:"bytes,1,opt,name=establishment_secret,json=establishmentSecret,proto3" json:"establishment_secret,omitempty"`
	// pending_stream_secret is the proposed secret ID to store as the pending stream
	// secret for this peering.
	PendingStreamSecret string `protobuf:"bytes,2,opt,name=pending_stream_secret,json=pendingStreamSecret,proto3" json:"pending_stream_secret,omitempty"`
	// contains filtered or unexported fields
}

ExchangeSecretRequest encodes a request to persist a pending stream secret secret. It is triggered by an acceptor peer generating a long-lived stream secret in exchange for an establishment secret.

func (*SecretsWriteRequest_ExchangeSecretRequest) Descriptor deprecated 

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

Deprecated: Use SecretsWriteRequest_ExchangeSecretRequest.ProtoReflect.Descriptor instead.

func (*SecretsWriteRequest_ExchangeSecretRequest) GetEstablishmentSecret 

func (x *SecretsWriteRequest_ExchangeSecretRequest) GetEstablishmentSecret() string

func (*SecretsWriteRequest_ExchangeSecretRequest) GetPendingStreamSecret 

func (x *SecretsWriteRequest_ExchangeSecretRequest) GetPendingStreamSecret() string

func (*SecretsWriteRequest_ExchangeSecretRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*SecretsWriteRequest_ExchangeSecretRequest) ProtoMessage 

func (*SecretsWriteRequest_ExchangeSecretRequest) ProtoMessage()

func (*SecretsWriteRequest_ExchangeSecretRequest) ProtoReflect 

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

func (*SecretsWriteRequest_ExchangeSecretRequest) Reset 

func (x *SecretsWriteRequest_ExchangeSecretRequest) Reset()

func (*SecretsWriteRequest_ExchangeSecretRequest) String 

func (x *SecretsWriteRequest_ExchangeSecretRequest) String() string

func (*SecretsWriteRequest_ExchangeSecretRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type SecretsWriteRequest_GenerateToken 

type SecretsWriteRequest_GenerateToken struct {
	GenerateToken *SecretsWriteRequest_GenerateTokenRequest `protobuf:"bytes,2,opt,name=generate_token,json=generateToken,proto3,oneof"`
}

type SecretsWriteRequest_GenerateTokenRequest 

type SecretsWriteRequest_GenerateTokenRequest struct {

	// establishment_secret is the proposed secret ID to store as the establishment
	// secret for this peering.
	EstablishmentSecret string `protobuf:"bytes,1,opt,name=establishment_secret,json=establishmentSecret,proto3" json:"establishment_secret,omitempty"`
	// contains filtered or unexported fields
}

GenerateTokenRequest encodes a request to persist a peering establishment secret. It is triggered by generating a new peering token for a peer cluster.

func (*SecretsWriteRequest_GenerateTokenRequest) Descriptor deprecated 

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

Deprecated: Use SecretsWriteRequest_GenerateTokenRequest.ProtoReflect.Descriptor instead.

func (*SecretsWriteRequest_GenerateTokenRequest) GetEstablishmentSecret 

func (x *SecretsWriteRequest_GenerateTokenRequest) GetEstablishmentSecret() string

func (*SecretsWriteRequest_GenerateTokenRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*SecretsWriteRequest_GenerateTokenRequest) ProtoMessage 

func (*SecretsWriteRequest_GenerateTokenRequest) ProtoMessage()

func (*SecretsWriteRequest_GenerateTokenRequest) ProtoReflect 

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

func (*SecretsWriteRequest_GenerateTokenRequest) Reset 

func (x *SecretsWriteRequest_GenerateTokenRequest) Reset()

func (*SecretsWriteRequest_GenerateTokenRequest) String 

func (x *SecretsWriteRequest_GenerateTokenRequest) String() string

func (*SecretsWriteRequest_GenerateTokenRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type SecretsWriteRequest_PromotePending 

type SecretsWriteRequest_PromotePending struct {
	PromotePending *SecretsWriteRequest_PromotePendingRequest `protobuf:"bytes,4,opt,name=promote_pending,json=promotePending,proto3,oneof"`
}

type SecretsWriteRequest_PromotePendingRequest 

type SecretsWriteRequest_PromotePendingRequest struct {

	// active_stream_secret is the proposed secret ID to store as the active stream
	// secret for this peering.
	ActiveStreamSecret string `protobuf:"bytes,1,opt,name=active_stream_secret,json=activeStreamSecret,proto3" json:"active_stream_secret,omitempty"`
	// contains filtered or unexported fields
}

PromotePendingRequest encodes a request to promote a pending stream secret to be an active stream secret. It is triggered when the accepting stream handler validates an Open request from a peer with a pending stream secret.

func (*SecretsWriteRequest_PromotePendingRequest) Descriptor deprecated 

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

Deprecated: Use SecretsWriteRequest_PromotePendingRequest.ProtoReflect.Descriptor instead.

func (*SecretsWriteRequest_PromotePendingRequest) GetActiveStreamSecret 

func (x *SecretsWriteRequest_PromotePendingRequest) GetActiveStreamSecret() string

func (*SecretsWriteRequest_PromotePendingRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*SecretsWriteRequest_PromotePendingRequest) ProtoMessage 

func (*SecretsWriteRequest_PromotePendingRequest) ProtoMessage()

func (*SecretsWriteRequest_PromotePendingRequest) ProtoReflect 

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

func (*SecretsWriteRequest_PromotePendingRequest) Reset 

func (x *SecretsWriteRequest_PromotePendingRequest) Reset()

func (*SecretsWriteRequest_PromotePendingRequest) String 

func (x *SecretsWriteRequest_PromotePendingRequest) String() string

func (*SecretsWriteRequest_PromotePendingRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type StreamStatus 

type StreamStatus struct {

	// ImportedServices is the list of services imported from this peering.
	ImportedServices []string `protobuf:"bytes,1,rep,name=ImportedServices,proto3" json:"ImportedServices,omitempty"`
	// ExportedServices is the list of services exported to this peering.
	ExportedServices []string `protobuf:"bytes,2,rep,name=ExportedServices,proto3" json:"ExportedServices,omitempty"`
	// LastHeartbeat represents when the last heartbeat message was received.
	LastHeartbeat *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=LastHeartbeat,proto3" json:"LastHeartbeat,omitempty"`
	// LastReceive represents when any message was last received, regardless of success or error.
	LastReceive *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=LastReceive,proto3" json:"LastReceive,omitempty"`
	// LastSend represents when any message was last sent, regardless of success or error.
	LastSend *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=LastSend,proto3" json:"LastSend,omitempty"`
	// contains filtered or unexported fields
}

StreamStatus represents information about an active peering stream.

func StreamStatusFromAPI 

func StreamStatusFromAPI(status api.PeeringStreamStatus) *StreamStatus

func (*StreamStatus) Descriptor deprecated 

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

Deprecated: Use StreamStatus.ProtoReflect.Descriptor instead.

func (*StreamStatus) GetExportedServices 

func (x *StreamStatus) GetExportedServices() []string

func (*StreamStatus) GetImportedServices 

func (x *StreamStatus) GetImportedServices() []string

func (*StreamStatus) GetLastHeartbeat 

func (x *StreamStatus) GetLastHeartbeat() *timestamppb.Timestamp

func (*StreamStatus) GetLastReceive 

func (x *StreamStatus) GetLastReceive() *timestamppb.Timestamp

func (*StreamStatus) GetLastSend 

func (x *StreamStatus) GetLastSend() *timestamppb.Timestamp

func (*StreamStatus) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*StreamStatus) ProtoMessage 

func (*StreamStatus) ProtoMessage()

func (*StreamStatus) ProtoReflect 

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

func (*StreamStatus) Reset 

func (x *StreamStatus) Reset()

func (*StreamStatus) String 

func (x *StreamStatus) String() string

func (*StreamStatus) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type TrustBundleListByServiceRequest 

type TrustBundleListByServiceRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=ServiceName,proto3" json:"ServiceName,omitempty"`
	Namespace   string `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	Partition   string `protobuf:"bytes,3,opt,name=Partition,proto3" json:"Partition,omitempty"`
	Kind        string `protobuf:"bytes,4,opt,name=Kind,proto3" json:"Kind,omitempty"`
	// contains filtered or unexported fields
}

func (*TrustBundleListByServiceRequest) Descriptor deprecated 

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

Deprecated: Use TrustBundleListByServiceRequest.ProtoReflect.Descriptor instead.

func (*TrustBundleListByServiceRequest) GetKind 

func (x *TrustBundleListByServiceRequest) GetKind() string

func (*TrustBundleListByServiceRequest) GetNamespace 

func (x *TrustBundleListByServiceRequest) GetNamespace() string

func (*TrustBundleListByServiceRequest) GetPartition 

func (x *TrustBundleListByServiceRequest) GetPartition() string

func (*TrustBundleListByServiceRequest) GetServiceName 

func (x *TrustBundleListByServiceRequest) GetServiceName() string

func (*TrustBundleListByServiceRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*TrustBundleListByServiceRequest) ProtoMessage 

func (*TrustBundleListByServiceRequest) ProtoMessage()

func (*TrustBundleListByServiceRequest) ProtoReflect 

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

func (*TrustBundleListByServiceRequest) RequestDatacenter 

func (req *TrustBundleListByServiceRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*TrustBundleListByServiceRequest) Reset 

func (x *TrustBundleListByServiceRequest) Reset()

func (*TrustBundleListByServiceRequest) String 

func (x *TrustBundleListByServiceRequest) String() string

func (*TrustBundleListByServiceRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type TrustBundleListByServiceResponse 

type TrustBundleListByServiceResponse struct {
	OBSOLETE_Index uint64                `protobuf:"varint,1,opt,name=OBSOLETE_Index,json=OBSOLETEIndex,proto3" json:"OBSOLETE_Index,omitempty"` // Deprecated in favor of gRPC metadata
	Bundles        []*PeeringTrustBundle `protobuf:"bytes,2,rep,name=Bundles,proto3" json:"Bundles,omitempty"`
	// contains filtered or unexported fields
}

func (*TrustBundleListByServiceResponse) Descriptor deprecated 

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

Deprecated: Use TrustBundleListByServiceResponse.ProtoReflect.Descriptor instead.

func (*TrustBundleListByServiceResponse) GetBundles 

func (x *TrustBundleListByServiceResponse) GetBundles() []*PeeringTrustBundle

func (*TrustBundleListByServiceResponse) GetOBSOLETE_Index 

func (x *TrustBundleListByServiceResponse) GetOBSOLETE_Index() uint64

func (*TrustBundleListByServiceResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*TrustBundleListByServiceResponse) ProtoMessage 

func (*TrustBundleListByServiceResponse) ProtoMessage()

func (*TrustBundleListByServiceResponse) ProtoReflect 

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

func (*TrustBundleListByServiceResponse) Reset 

func (x *TrustBundleListByServiceResponse) Reset()

func (*TrustBundleListByServiceResponse) String 

func (x *TrustBundleListByServiceResponse) String() string

func (*TrustBundleListByServiceResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type TrustBundleReadRequest 

type TrustBundleReadRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Partition string `protobuf:"bytes,2,opt,name=Partition,proto3" json:"Partition,omitempty"`
	// contains filtered or unexported fields
}

func (*TrustBundleReadRequest) Descriptor deprecated 

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

Deprecated: Use TrustBundleReadRequest.ProtoReflect.Descriptor instead.

func (*TrustBundleReadRequest) GetName 

func (x *TrustBundleReadRequest) GetName() string

func (*TrustBundleReadRequest) GetPartition 

func (x *TrustBundleReadRequest) GetPartition() string

func (*TrustBundleReadRequest) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*TrustBundleReadRequest) ProtoMessage 

func (*TrustBundleReadRequest) ProtoMessage()

func (*TrustBundleReadRequest) ProtoReflect 

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

func (*TrustBundleReadRequest) RequestDatacenter 

func (req *TrustBundleReadRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*TrustBundleReadRequest) Reset 

func (x *TrustBundleReadRequest) Reset()

func (*TrustBundleReadRequest) String 

func (x *TrustBundleReadRequest) String() string

func (*TrustBundleReadRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type TrustBundleReadResponse 

type TrustBundleReadResponse struct {
	OBSOLETE_Index uint64              `protobuf:"varint,1,opt,name=OBSOLETE_Index,json=OBSOLETEIndex,proto3" json:"OBSOLETE_Index,omitempty"` // Deprecated in favor of gRPC metadata
	Bundle         *PeeringTrustBundle `protobuf:"bytes,2,opt,name=Bundle,proto3" json:"Bundle,omitempty"`
	// contains filtered or unexported fields
}

func (*TrustBundleReadResponse) Descriptor deprecated 

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

Deprecated: Use TrustBundleReadResponse.ProtoReflect.Descriptor instead.

func (*TrustBundleReadResponse) GetBundle 

func (x *TrustBundleReadResponse) GetBundle() *PeeringTrustBundle

func (*TrustBundleReadResponse) GetOBSOLETE_Index 

func (x *TrustBundleReadResponse) GetOBSOLETE_Index() uint64

func (*TrustBundleReadResponse) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*TrustBundleReadResponse) ProtoMessage 

func (*TrustBundleReadResponse) ProtoMessage()

func (*TrustBundleReadResponse) ProtoReflect 

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

func (*TrustBundleReadResponse) Reset 

func (x *TrustBundleReadResponse) Reset()

func (*TrustBundleReadResponse) String 

func (x *TrustBundleReadResponse) String() string

func (*TrustBundleReadResponse) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type UnimplementedPeeringServiceServer 

type UnimplementedPeeringServiceServer struct {
}

UnimplementedPeeringServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedPeeringServiceServer) Establish 

func (UnimplementedPeeringServiceServer) Establish(context.Context, *EstablishRequest) (*EstablishResponse, error)

func (UnimplementedPeeringServiceServer) GenerateToken 

func (UnimplementedPeeringServiceServer) GenerateToken(context.Context, *GenerateTokenRequest) (*GenerateTokenResponse, error)

func (UnimplementedPeeringServiceServer) PeeringDelete 

func (UnimplementedPeeringServiceServer) PeeringDelete(context.Context, *PeeringDeleteRequest) (*PeeringDeleteResponse, error)

func (UnimplementedPeeringServiceServer) PeeringList 

func (UnimplementedPeeringServiceServer) PeeringList(context.Context, *PeeringListRequest) (*PeeringListResponse, error)

func (UnimplementedPeeringServiceServer) PeeringRead 

func (UnimplementedPeeringServiceServer) PeeringRead(context.Context, *PeeringReadRequest) (*PeeringReadResponse, error)

func (UnimplementedPeeringServiceServer) PeeringWrite 

func (UnimplementedPeeringServiceServer) PeeringWrite(context.Context, *PeeringWriteRequest) (*PeeringWriteResponse, error)

func (UnimplementedPeeringServiceServer) TrustBundleListByService 

func (UnimplementedPeeringServiceServer) TrustBundleListByService(context.Context, *TrustBundleListByServiceRequest) (*TrustBundleListByServiceResponse, error)

func (UnimplementedPeeringServiceServer) TrustBundleRead 

func (UnimplementedPeeringServiceServer) TrustBundleRead(context.Context, *TrustBundleReadRequest) (*TrustBundleReadResponse, error)

type UnsafePeeringServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.