pbpeering

package
v1.13.0-alpha2 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2022 License: MPL-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TypeURLService = "type.googleapis.com/consul.api.Service"
	TypeURLRoots   = "type.googleapis.com/consul.api.CARoots"
)

Variables

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

Enum value maps for PeeringState.

View Source 
var (
	ReplicationMessage_Response_Operation_name = map[int32]string{
		0: "Unknown",
		1: "UPSERT",
		2: "DELETE",
	}
	ReplicationMessage_Response_Operation_value = map[string]int32{
		"Unknown": 0,
		"UPSERT":  1,
		"DELETE":  2,
	}
)

Enum value maps for ReplicationMessage_Response_Operation.

View Source 
var File_proto_pbpeering_peering_proto protoreflect.FileDescriptor
View Source 
var PeeringService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "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{
		{
			StreamName:    "StreamResources",
			Handler:       _PeeringService_StreamResources_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proto/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 KnownTypeURL 

func KnownTypeURL(s string) bool

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 TimePtrFromProto 

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

func TimePtrToProto 

func TimePtrToProto(s *time.Time) *timestamp.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"`
	// these are common fields required for implementing structs.RPCInfo methods
	// that are used to forward requests
	Datacenter string `protobuf:"bytes,4,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
	Token      string `protobuf:"bytes,5,opt,name=Token,proto3" json:"Token,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
}

@consul-rpc-glue: Datacenter

mog annotation:

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

func NewEstablishRequestFromAPI 

func NewEstablishRequestFromAPI(req *api.PeeringEstablishRequest) *EstablishRequest

convenience

func (*EstablishRequest) AllowStaleRead 

func (req *EstablishRequest) AllowStaleRead() bool

AllowStaleRead implements structs.RPCInfo

func (*EstablishRequest) Descriptor deprecated 

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

Deprecated: Use EstablishRequest.ProtoReflect.Descriptor instead.

func (*EstablishRequest) GetDatacenter 

func (x *EstablishRequest) GetDatacenter() string

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

func (x *EstablishRequest) GetToken() string

func (*EstablishRequest) HasTimedOut 

func (req *EstablishRequest) HasTimedOut(start time.Time, rpcHoldTimeout, _, _ time.Duration) (bool, error)

HasTimedOut implements structs.RPCInfo

func (*EstablishRequest) IsRead 

func (req *EstablishRequest) IsRead() bool

IsRead implements structs.RPCInfo

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 (msg *EstablishRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*EstablishRequest) Reset 

func (x *EstablishRequest) Reset()

func (*EstablishRequest) SetTokenSecret 

func (req *EstablishRequest) SetTokenSecret(token string)

SetTokenSecret implements structs.RPCInfo

func (*EstablishRequest) String 

func (x *EstablishRequest) String() string

func (*EstablishRequest) Timeout 

func (msg *EstablishRequest) Timeout(rpcHoldTimeout time.Duration, maxQueryTime time.Duration, defaultQueryTime time.Duration) time.Duration

Timeout implements structs.RPCInfo

func (*EstablishRequest) TokenSecret 

func (req *EstablishRequest) TokenSecret() string

TokenSecret implements structs.RPCInfo

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/hashicorp/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"`
	// these are common fields required for implementing structs.RPCInfo methods
	// that are used to forward requests
	Datacenter string `protobuf:"bytes,3,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
	Token      string `protobuf:"bytes,4,opt,name=Token,proto3" json:"Token,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/hashicorp/consul/api.PeeringGenerateTokenRequest output=peering.gen.go name=API

func NewGenerateTokenRequestFromAPI 

func NewGenerateTokenRequestFromAPI(req *api.PeeringGenerateTokenRequest) *GenerateTokenRequest

convenience

func (*GenerateTokenRequest) AllowStaleRead 

func (req *GenerateTokenRequest) AllowStaleRead() bool

AllowStaleRead implements structs.RPCInfo

func (*GenerateTokenRequest) Descriptor deprecated 

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

Deprecated: Use GenerateTokenRequest.ProtoReflect.Descriptor instead.

func (*GenerateTokenRequest) GetDatacenter 

func (x *GenerateTokenRequest) GetDatacenter() string

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

func (x *GenerateTokenRequest) GetToken() string

func (*GenerateTokenRequest) HasTimedOut 

func (req *GenerateTokenRequest) HasTimedOut(start time.Time, rpcHoldTimeout, _, _ time.Duration) (bool, error)

HasTimedOut implements structs.RPCInfo

func (*GenerateTokenRequest) IsRead 

func (req *GenerateTokenRequest) IsRead() bool

IsRead implements structs.RPCInfo

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

func (req *GenerateTokenRequest) SetTokenSecret(token string)

SetTokenSecret implements structs.RPCInfo

func (*GenerateTokenRequest) String 

func (x *GenerateTokenRequest) String() string

func (*GenerateTokenRequest) Timeout 

func (msg *GenerateTokenRequest) Timeout(rpcHoldTimeout time.Duration, maxQueryTime time.Duration, defaultQueryTime time.Duration) time.Duration

Timeout implements structs.RPCInfo

func (*GenerateTokenRequest) TokenSecret 

func (req *GenerateTokenRequest) TokenSecret() string

TokenSecret implements structs.RPCInfo

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/hashicorp/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 LeaderAddress 

type LeaderAddress struct {

	// address is an ip:port best effort hint at what could be the cluster leader's address
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

LeaderAddress is sent when the peering service runs on a consul node that is not a leader. The node either lost leadership, or never was a leader.

func (*LeaderAddress) Descriptor deprecated 

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

Deprecated: Use LeaderAddress.ProtoReflect.Descriptor instead.

func (*LeaderAddress) GetAddress 

func (x *LeaderAddress) GetAddress() string

func (*LeaderAddress) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*LeaderAddress) ProtoMessage 

func (*LeaderAddress) ProtoMessage()

func (*LeaderAddress) ProtoReflect 

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

func (*LeaderAddress) Reset 

func (x *LeaderAddress) Reset()

func (*LeaderAddress) String 

func (x *LeaderAddress) String() string

func (*LeaderAddress) UnmarshalBinary 

func (msg *LeaderAddress) 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=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"`
	// CreateIndex is the Raft index at which the Peering was created.
	CreateIndex uint64 `protobuf:"varint,11,opt,name=CreateIndex,proto3" json:"CreateIndex,omitempty"`
	// ModifyIndex is the latest Raft index at which the Peering. was modified.
	ModifyIndex uint64 `protobuf:"varint,12,opt,name=ModifyIndex,proto3" json:"ModifyIndex,omitempty"`
	// contains filtered or unexported fields
}

Peering defines a peering relationship between two disparate Consul clusters

mog annotation:

target=github.com/hashicorp/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) 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) 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) GetState 

func (x *Peering) GetState() PeeringState

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. 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) 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"`
	//TODO(peering): what to do with embedded write request?
	Datacenter string `protobuf:"bytes,3,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
	// contains filtered or unexported fields
}

@consul-rpc-glue: Datacenter,WriteTODO

func (*PeeringDeleteRequest) AllowStaleRead 

func (msg *PeeringDeleteRequest) AllowStaleRead() bool

AllowStaleRead implements structs.RPCInfo

func (*PeeringDeleteRequest) Descriptor deprecated 

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

Deprecated: Use PeeringDeleteRequest.ProtoReflect.Descriptor instead.

func (*PeeringDeleteRequest) GetDatacenter 

func (x *PeeringDeleteRequest) GetDatacenter() string

func (*PeeringDeleteRequest) GetName 

func (x *PeeringDeleteRequest) GetName() string

func (*PeeringDeleteRequest) GetPartition 

func (x *PeeringDeleteRequest) GetPartition() string

func (*PeeringDeleteRequest) HasTimedOut 

func (msg *PeeringDeleteRequest) HasTimedOut(start time.Time, rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) (bool, error)

HasTimedOut implements structs.RPCInfo

func (*PeeringDeleteRequest) IsRead 

func (msg *PeeringDeleteRequest) IsRead() bool

IsRead implements structs.RPCInfo

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 (msg *PeeringDeleteRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*PeeringDeleteRequest) Reset 

func (x *PeeringDeleteRequest) Reset()

func (*PeeringDeleteRequest) SetTokenSecret 

func (msg *PeeringDeleteRequest) SetTokenSecret(s string)

SetTokenSecret implements structs.RPCInfo

func (*PeeringDeleteRequest) String 

func (x *PeeringDeleteRequest) String() string

func (*PeeringDeleteRequest) Timeout 

func (msg *PeeringDeleteRequest) Timeout(rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) time.Duration

Timeout implements structs.RPCInfo

func (*PeeringDeleteRequest) TokenSecret 

func (msg *PeeringDeleteRequest) TokenSecret() string

TokenSecret implements structs.RPCInfo

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"`
	Datacenter string `protobuf:"bytes,2,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
	// contains filtered or unexported fields
}

@consul-rpc-glue: Datacenter,ReadTODO

func (*PeeringListRequest) AllowStaleRead 

func (msg *PeeringListRequest) AllowStaleRead() bool

AllowStaleRead implements structs.RPCInfo

func (*PeeringListRequest) Descriptor deprecated 

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

Deprecated: Use PeeringListRequest.ProtoReflect.Descriptor instead.

func (*PeeringListRequest) GetDatacenter 

func (x *PeeringListRequest) GetDatacenter() string

func (*PeeringListRequest) GetPartition 

func (x *PeeringListRequest) GetPartition() string

func (*PeeringListRequest) HasTimedOut 

func (msg *PeeringListRequest) HasTimedOut(start time.Time, rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) (bool, error)

HasTimedOut implements structs.RPCInfo

func (*PeeringListRequest) IsRead 

func (msg *PeeringListRequest) IsRead() bool

IsRead implements structs.RPCInfo

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 (msg *PeeringListRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*PeeringListRequest) Reset 

func (x *PeeringListRequest) Reset()

func (*PeeringListRequest) SetTokenSecret 

func (msg *PeeringListRequest) SetTokenSecret(s string)

SetTokenSecret implements structs.RPCInfo

func (*PeeringListRequest) String 

func (x *PeeringListRequest) String() string

func (*PeeringListRequest) Timeout 

func (msg *PeeringListRequest) Timeout(rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) time.Duration

Timeout implements structs.RPCInfo

func (*PeeringListRequest) Token 

func (msg *PeeringListRequest) Token() string

Token implements structs.RPCInfo

func (*PeeringListRequest) TokenSecret 

func (msg *PeeringListRequest) TokenSecret() string

TokenSecret implements structs.RPCInfo

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"`
	// contains filtered or unexported fields
}

func (*PeeringListResponse) Descriptor deprecated 

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

Deprecated: Use PeeringListResponse.ProtoReflect.Descriptor instead.

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"`
	Datacenter string `protobuf:"bytes,3,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
	// contains filtered or unexported fields
}

@consul-rpc-glue: Datacenter,ReadTODO

func (*PeeringReadRequest) AllowStaleRead 

func (msg *PeeringReadRequest) AllowStaleRead() bool

AllowStaleRead implements structs.RPCInfo

func (*PeeringReadRequest) Descriptor deprecated 

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

Deprecated: Use PeeringReadRequest.ProtoReflect.Descriptor instead.

func (*PeeringReadRequest) GetDatacenter 

func (x *PeeringReadRequest) GetDatacenter() string

func (*PeeringReadRequest) GetName 

func (x *PeeringReadRequest) GetName() string

func (*PeeringReadRequest) GetPartition 

func (x *PeeringReadRequest) GetPartition() string

func (*PeeringReadRequest) HasTimedOut 

func (msg *PeeringReadRequest) HasTimedOut(start time.Time, rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) (bool, error)

HasTimedOut implements structs.RPCInfo

func (*PeeringReadRequest) IsRead 

func (msg *PeeringReadRequest) IsRead() bool

IsRead implements structs.RPCInfo

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 (msg *PeeringReadRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*PeeringReadRequest) Reset 

func (x *PeeringReadRequest) Reset()

func (*PeeringReadRequest) SetTokenSecret 

func (msg *PeeringReadRequest) SetTokenSecret(s string)

SetTokenSecret implements structs.RPCInfo

func (*PeeringReadRequest) String 

func (x *PeeringReadRequest) String() string

func (*PeeringReadRequest) Timeout 

func (msg *PeeringReadRequest) Timeout(rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) time.Duration

Timeout implements structs.RPCInfo

func (*PeeringReadRequest) Token 

func (msg *PeeringReadRequest) Token() string

Token implements structs.RPCInfo

func (*PeeringReadRequest) TokenSecret 

func (msg *PeeringReadRequest) TokenSecret() string

TokenSecret implements structs.RPCInfo

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 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)
	// StreamResources opens an event stream for resources to share between peers, such as services.
	// Events are streamed as they happen.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	StreamResources(ctx context.Context, opts ...grpc.CallOption) (PeeringService_StreamResourcesClient, 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)
	// StreamResources opens an event stream for resources to share between peers, such as services.
	// Events are streamed as they happen.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	StreamResources(PeeringService_StreamResourcesServer) error
}

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

type PeeringService_StreamResourcesClient 

type PeeringService_StreamResourcesClient interface {
	Send(*ReplicationMessage) error
	Recv() (*ReplicationMessage, error)
	grpc.ClientStream
}

type PeeringService_StreamResourcesServer 

type PeeringService_StreamResourcesServer interface {
	Send(*ReplicationMessage) error
	Recv() (*ReplicationMessage, error)
	grpc.ServerStream
}

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
	// Initial means a Peering has been initialized and is awaiting
	// acknowledgement from a remote peer.
	PeeringState_INITIAL PeeringState = 1
	// Active means that the peering connection is active and healthy.
	PeeringState_ACTIVE PeeringState = 2
	// Failing means the peering connection has been interrupted but has not yet
	// been terminated.
	PeeringState_FAILING PeeringState = 3
	// Terminated means the peering relationship has been removed.
	PeeringState_TERMINATED PeeringState = 4
)

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
}

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.
	CreateIndex uint64 `protobuf:"varint,6,opt,name=CreateIndex,proto3" json:"CreateIndex,omitempty"`
	// ModifyIndex is the latest Raft index at which the trust bundle was modified.
	ModifyIndex uint64 `protobuf:"varint,7,opt,name=ModifyIndex,proto3" json:"ModifyIndex,omitempty"`
	// 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) 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"`
	//TODO(peering): what to do with embedded write request?
	Datacenter string `protobuf:"bytes,3,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
	// contains filtered or unexported fields
}

@consul-rpc-glue: Datacenter

func (*PeeringTrustBundleDeleteRequest) Descriptor deprecated 

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

Deprecated: Use PeeringTrustBundleDeleteRequest.ProtoReflect.Descriptor instead.

func (*PeeringTrustBundleDeleteRequest) GetDatacenter 

func (x *PeeringTrustBundleDeleteRequest) GetDatacenter() string

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

func (msg *PeeringTrustBundleDeleteRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

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"`
	//TODO(peering): what to do with embedded write request?
	Datacenter string `protobuf:"bytes,2,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
	// contains filtered or unexported fields
}

@consul-rpc-glue: Datacenter

func (*PeeringTrustBundleWriteRequest) Descriptor deprecated 

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

Deprecated: Use PeeringTrustBundleWriteRequest.ProtoReflect.Descriptor instead.

func (*PeeringTrustBundleWriteRequest) GetDatacenter 

func (x *PeeringTrustBundleWriteRequest) GetDatacenter() string

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

func (msg *PeeringTrustBundleWriteRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

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 *Peering `protobuf:"bytes,1,opt,name=Peering,proto3" json:"Peering,omitempty"`
	//TODO(peering): what to do with embedded write request?
	Datacenter string `protobuf:"bytes,2,opt,name=Datacenter,proto3" json:"Datacenter,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
}

@consul-rpc-glue: Datacenter,WriteTODO

func (*PeeringWriteRequest) AllowStaleRead 

func (msg *PeeringWriteRequest) AllowStaleRead() bool

AllowStaleRead implements structs.RPCInfo

func (*PeeringWriteRequest) Descriptor deprecated 

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

Deprecated: Use PeeringWriteRequest.ProtoReflect.Descriptor instead.

func (*PeeringWriteRequest) GetDatacenter 

func (x *PeeringWriteRequest) GetDatacenter() string

func (*PeeringWriteRequest) GetMeta 

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

func (*PeeringWriteRequest) GetPeering 

func (x *PeeringWriteRequest) GetPeering() *Peering

func (*PeeringWriteRequest) HasTimedOut 

func (msg *PeeringWriteRequest) HasTimedOut(start time.Time, rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) (bool, error)

HasTimedOut implements structs.RPCInfo

func (*PeeringWriteRequest) IsRead 

func (msg *PeeringWriteRequest) IsRead() bool

IsRead implements structs.RPCInfo

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 (msg *PeeringWriteRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*PeeringWriteRequest) Reset 

func (x *PeeringWriteRequest) Reset()

func (*PeeringWriteRequest) SetTokenSecret 

func (msg *PeeringWriteRequest) SetTokenSecret(s string)

SetTokenSecret implements structs.RPCInfo

func (*PeeringWriteRequest) String 

func (x *PeeringWriteRequest) String() string

func (*PeeringWriteRequest) Timeout 

func (msg *PeeringWriteRequest) Timeout(rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) time.Duration

Timeout implements structs.RPCInfo

func (*PeeringWriteRequest) TokenSecret 

func (msg *PeeringWriteRequest) TokenSecret() string

TokenSecret implements structs.RPCInfo

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 ReplicationMessage 

type ReplicationMessage struct {

	// Types that are assignable to Payload:
	//	*ReplicationMessage_Request_
	//	*ReplicationMessage_Response_
	//	*ReplicationMessage_Terminated_
	Payload isReplicationMessage_Payload `protobuf_oneof:"Payload"`
	// contains filtered or unexported fields
}

func (*ReplicationMessage) Descriptor deprecated 

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

Deprecated: Use ReplicationMessage.ProtoReflect.Descriptor instead.

func (*ReplicationMessage) GetPayload 

func (m *ReplicationMessage) GetPayload() isReplicationMessage_Payload

func (*ReplicationMessage) GetRequest 

func (x *ReplicationMessage) GetRequest() *ReplicationMessage_Request

func (*ReplicationMessage) GetResponse 

func (x *ReplicationMessage) GetResponse() *ReplicationMessage_Response

func (*ReplicationMessage) GetTerminated 

func (x *ReplicationMessage) GetTerminated() *ReplicationMessage_Terminated

func (*ReplicationMessage) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*ReplicationMessage) ProtoMessage 

func (*ReplicationMessage) ProtoMessage()

func (*ReplicationMessage) ProtoReflect 

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

func (*ReplicationMessage) Reset 

func (x *ReplicationMessage) Reset()

func (*ReplicationMessage) String 

func (x *ReplicationMessage) String() string

func (*ReplicationMessage) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type ReplicationMessage_Request 

type ReplicationMessage_Request struct {

	// An identifier for the peer making the request.
	// This identifier is provisioned by the serving peer prior to the request from the dialing peer.
	PeerID string `protobuf:"bytes,1,opt,name=PeerID,proto3" json:"PeerID,omitempty"`
	// Nonce corresponding to that of the response being ACKed or NACKed.
	// Initial subscription requests will have an empty nonce.
	// The nonce is generated and incremented by the exporting peer.
	Nonce string `protobuf:"bytes,2,opt,name=Nonce,proto3" json:"Nonce,omitempty"`
	// The type URL for the resource being requested or ACK/NACKed.
	ResourceURL string `protobuf:"bytes,3,opt,name=ResourceURL,proto3" json:"ResourceURL,omitempty"`
	// The error if the previous response was not applied successfully.
	// This field is empty in the first subscription request.
	Error *pbstatus.Status `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

A Request requests to subscribe to a resource of a given type.

func (*ReplicationMessage_Request) Descriptor deprecated 

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

Deprecated: Use ReplicationMessage_Request.ProtoReflect.Descriptor instead.

func (*ReplicationMessage_Request) GetError 

func (x *ReplicationMessage_Request) GetError() *pbstatus.Status

func (*ReplicationMessage_Request) GetNonce 

func (x *ReplicationMessage_Request) GetNonce() string

func (*ReplicationMessage_Request) GetPeerID 

func (x *ReplicationMessage_Request) GetPeerID() string

func (*ReplicationMessage_Request) GetResourceURL 

func (x *ReplicationMessage_Request) GetResourceURL() string

func (*ReplicationMessage_Request) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*ReplicationMessage_Request) ProtoMessage 

func (*ReplicationMessage_Request) ProtoMessage()

func (*ReplicationMessage_Request) ProtoReflect 

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

func (*ReplicationMessage_Request) Reset 

func (x *ReplicationMessage_Request) Reset()

func (*ReplicationMessage_Request) String 

func (x *ReplicationMessage_Request) String() string

func (*ReplicationMessage_Request) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type ReplicationMessage_Request_ 

type ReplicationMessage_Request_ struct {
	Request *ReplicationMessage_Request `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type ReplicationMessage_Response 

type ReplicationMessage_Response struct {

	// Nonce identifying a response in a stream.
	Nonce string `protobuf:"bytes,1,opt,name=Nonce,proto3" json:"Nonce,omitempty"`
	// The type URL of resource being returned.
	ResourceURL string `protobuf:"bytes,2,opt,name=ResourceURL,proto3" json:"ResourceURL,omitempty"`
	// An identifier for the resource being returned.
	// This could be the SPIFFE ID of the service.
	ResourceID string `protobuf:"bytes,3,opt,name=ResourceID,proto3" json:"ResourceID,omitempty"`
	// The resource being returned.
	Resource *anypb.Any `protobuf:"bytes,4,opt,name=Resource,proto3" json:"Resource,omitempty"`
	// REQUIRED. The operation to be performed in relation to the resource.
	Operation ReplicationMessage_Response_Operation `protobuf:"varint,5,opt,name=operation,proto3,enum=peering.ReplicationMessage_Response_Operation" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

A Response contains resources corresponding to a subscription request.

func (*ReplicationMessage_Response) Descriptor deprecated 

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

Deprecated: Use ReplicationMessage_Response.ProtoReflect.Descriptor instead.

func (*ReplicationMessage_Response) GetNonce 

func (x *ReplicationMessage_Response) GetNonce() string

func (*ReplicationMessage_Response) GetOperation 

func (x *ReplicationMessage_Response) GetOperation() ReplicationMessage_Response_Operation

func (*ReplicationMessage_Response) GetResource 

func (x *ReplicationMessage_Response) GetResource() *anypb.Any

func (*ReplicationMessage_Response) GetResourceID 

func (x *ReplicationMessage_Response) GetResourceID() string

func (*ReplicationMessage_Response) GetResourceURL 

func (x *ReplicationMessage_Response) GetResourceURL() string

func (*ReplicationMessage_Response) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*ReplicationMessage_Response) ProtoMessage 

func (*ReplicationMessage_Response) ProtoMessage()

func (*ReplicationMessage_Response) ProtoReflect 

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

func (*ReplicationMessage_Response) Reset 

func (x *ReplicationMessage_Response) Reset()

func (*ReplicationMessage_Response) String 

func (x *ReplicationMessage_Response) String() string

func (*ReplicationMessage_Response) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type ReplicationMessage_Response_ 

type ReplicationMessage_Response_ struct {
	Response *ReplicationMessage_Response `protobuf:"bytes,2,opt,name=response,proto3,oneof"`
}

type ReplicationMessage_Response_Operation 

type ReplicationMessage_Response_Operation int32

Operation enumerates supported operations for replicated resources. 

const (
	ReplicationMessage_Response_Unknown ReplicationMessage_Response_Operation = 0
	// UPSERT represents a create or update event.
	ReplicationMessage_Response_UPSERT ReplicationMessage_Response_Operation = 1
	// DELETE indicates the resource should be deleted.
	// In DELETE operations no Resource will be returned.
	// Deletion by an importing peer must be done with the type URL and ID.
	ReplicationMessage_Response_DELETE ReplicationMessage_Response_Operation = 2
)

func (ReplicationMessage_Response_Operation) Descriptor 

func (ReplicationMessage_Response_Operation) Descriptor() protoreflect.EnumDescriptor

func (ReplicationMessage_Response_Operation) Enum 

func (x ReplicationMessage_Response_Operation) Enum() *ReplicationMessage_Response_Operation

func (ReplicationMessage_Response_Operation) EnumDescriptor deprecated 

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

Deprecated: Use ReplicationMessage_Response_Operation.Descriptor instead.

func (ReplicationMessage_Response_Operation) GoString 

func (x ReplicationMessage_Response_Operation) GoString() string

func (ReplicationMessage_Response_Operation) Number 

func (x ReplicationMessage_Response_Operation) Number() protoreflect.EnumNumber

func (ReplicationMessage_Response_Operation) String 

func (x ReplicationMessage_Response_Operation) String() string

func (ReplicationMessage_Response_Operation) Type 

func (ReplicationMessage_Response_Operation) Type() protoreflect.EnumType

type ReplicationMessage_Terminated 

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

Terminated is sent when a peering is deleted locally. This message signals to the peer that they should clean up their local state about the peering.

func (*ReplicationMessage_Terminated) Descriptor deprecated 

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

Deprecated: Use ReplicationMessage_Terminated.ProtoReflect.Descriptor instead.

func (*ReplicationMessage_Terminated) MarshalBinary 

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

MarshalBinary implements encoding.BinaryMarshaler

func (*ReplicationMessage_Terminated) ProtoMessage 

func (*ReplicationMessage_Terminated) ProtoMessage()

func (*ReplicationMessage_Terminated) ProtoReflect 

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

func (*ReplicationMessage_Terminated) Reset 

func (x *ReplicationMessage_Terminated) Reset()

func (*ReplicationMessage_Terminated) String 

func (x *ReplicationMessage_Terminated) String() string

func (*ReplicationMessage_Terminated) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type ReplicationMessage_Terminated_ 

type ReplicationMessage_Terminated_ struct {
	Terminated *ReplicationMessage_Terminated `protobuf:"bytes,3,opt,name=terminated,proto3,oneof"`
}

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"`
	// these are common fields required for implementing structs.RPCInfo methods
	// that are used to forward requests
	Datacenter string `protobuf:"bytes,5,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
	// contains filtered or unexported fields
}

@consul-rpc-glue: Datacenter,ReadTODO

func (*TrustBundleListByServiceRequest) AllowStaleRead 

func (msg *TrustBundleListByServiceRequest) AllowStaleRead() bool

AllowStaleRead implements structs.RPCInfo

func (*TrustBundleListByServiceRequest) CacheInfo 

func (r *TrustBundleListByServiceRequest) CacheInfo() cache.RequestInfo

func (*TrustBundleListByServiceRequest) Descriptor deprecated 

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

Deprecated: Use TrustBundleListByServiceRequest.ProtoReflect.Descriptor instead.

func (*TrustBundleListByServiceRequest) GetDatacenter 

func (x *TrustBundleListByServiceRequest) GetDatacenter() string

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

func (msg *TrustBundleListByServiceRequest) HasTimedOut(start time.Time, rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) (bool, error)

HasTimedOut implements structs.RPCInfo

func (*TrustBundleListByServiceRequest) IsRead 

func (msg *TrustBundleListByServiceRequest) IsRead() bool

IsRead implements structs.RPCInfo

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 (msg *TrustBundleListByServiceRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*TrustBundleListByServiceRequest) Reset 

func (x *TrustBundleListByServiceRequest) Reset()

func (*TrustBundleListByServiceRequest) SetTokenSecret 

func (msg *TrustBundleListByServiceRequest) SetTokenSecret(s string)

SetTokenSecret implements structs.RPCInfo

func (*TrustBundleListByServiceRequest) String 

func (x *TrustBundleListByServiceRequest) String() string

func (*TrustBundleListByServiceRequest) Timeout 

func (msg *TrustBundleListByServiceRequest) Timeout(rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) time.Duration

Timeout implements structs.RPCInfo

func (*TrustBundleListByServiceRequest) Token 

func (msg *TrustBundleListByServiceRequest) Token() string

Token implements structs.RPCInfo

func (*TrustBundleListByServiceRequest) TokenSecret 

func (msg *TrustBundleListByServiceRequest) TokenSecret() string

TokenSecret implements structs.RPCInfo

func (*TrustBundleListByServiceRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type TrustBundleListByServiceResponse 

type TrustBundleListByServiceResponse struct {
	Index   uint64                `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"`
	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) GetIndex 

func (x *TrustBundleListByServiceResponse) GetIndex() 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"`
	// these are common fields required for implementing structs.RPCInfo methods
	// that are used to forward requests
	Datacenter string `protobuf:"bytes,3,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
	// contains filtered or unexported fields
}

@consul-rpc-glue: Datacenter,ReadTODO

func (*TrustBundleReadRequest) AllowStaleRead 

func (msg *TrustBundleReadRequest) AllowStaleRead() bool

AllowStaleRead implements structs.RPCInfo

func (*TrustBundleReadRequest) CacheInfo 

func (r *TrustBundleReadRequest) CacheInfo() cache.RequestInfo

func (*TrustBundleReadRequest) Descriptor deprecated 

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

Deprecated: Use TrustBundleReadRequest.ProtoReflect.Descriptor instead.

func (*TrustBundleReadRequest) GetDatacenter 

func (x *TrustBundleReadRequest) GetDatacenter() string

func (*TrustBundleReadRequest) GetName 

func (x *TrustBundleReadRequest) GetName() string

func (*TrustBundleReadRequest) GetPartition 

func (x *TrustBundleReadRequest) GetPartition() string

func (*TrustBundleReadRequest) HasTimedOut 

func (msg *TrustBundleReadRequest) HasTimedOut(start time.Time, rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) (bool, error)

HasTimedOut implements structs.RPCInfo

func (*TrustBundleReadRequest) IsRead 

func (msg *TrustBundleReadRequest) IsRead() bool

IsRead implements structs.RPCInfo

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 (msg *TrustBundleReadRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*TrustBundleReadRequest) Reset 

func (x *TrustBundleReadRequest) Reset()

func (*TrustBundleReadRequest) SetTokenSecret 

func (msg *TrustBundleReadRequest) SetTokenSecret(s string)

SetTokenSecret implements structs.RPCInfo

func (*TrustBundleReadRequest) String 

func (x *TrustBundleReadRequest) String() string

func (*TrustBundleReadRequest) Timeout 

func (msg *TrustBundleReadRequest) Timeout(rpcHoldTimeout time.Duration, a time.Duration, b time.Duration) time.Duration

Timeout implements structs.RPCInfo

func (*TrustBundleReadRequest) Token 

func (msg *TrustBundleReadRequest) Token() string

Token implements structs.RPCInfo

func (*TrustBundleReadRequest) TokenSecret 

func (msg *TrustBundleReadRequest) TokenSecret() string

TokenSecret implements structs.RPCInfo

func (*TrustBundleReadRequest) UnmarshalBinary 

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

UnmarshalBinary implements encoding.BinaryUnmarshaler

type TrustBundleReadResponse 

type TrustBundleReadResponse struct {
	Index  uint64              `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"`
	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) GetIndex 

func (x *TrustBundleReadResponse) GetIndex() 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) StreamResources 

func (UnimplementedPeeringServiceServer) StreamResources(PeeringService_StreamResourcesServer) 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.