pbpeering

package
v1.13.2 Latest Latest
Warning

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

Go to latest
Published: Sep 20, 2022 License: MPL-2.0 Imports: 20 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_proto_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: "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 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"`
	// 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.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/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

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

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"`
	// ImportedServiceCount is the count of how many services are imported from this peering.
	ImportedServiceCount uint64 `protobuf:"varint,13,opt,name=ImportedServiceCount,proto3" json:"ImportedServiceCount,omitempty"`
	// ExportedServiceCount is the count of how many services are exported to this peering.
	ExportedServiceCount uint64 `protobuf:"varint,14,opt,name=ExportedServiceCount,proto3" json:"ExportedServiceCount,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:"-"`
	// 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) GetExportedServiceCount

func (x *Peering) GetExportedServiceCount() uint64

func (*Peering) GetID

func (x *Peering) GetID() string

func (*Peering) GetImportedServiceCount

func (x *Peering) GetImportedServiceCount() uint64

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

@consul-rpc-glue: LeaderReadTODO

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

@consul-rpc-glue: LeaderReadTODO

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) 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 (req *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 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 (*PeeringSecrets_Establishment) Reset

func (x *PeeringSecrets_Establishment) Reset()

func (*PeeringSecrets_Establishment) 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 added in v1.13.2

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 added in v1.13.2

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

Deprecated: Use PeeringServerAddresses.ProtoReflect.Descriptor instead.

func (*PeeringServerAddresses) GetAddresses added in v1.13.2

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

func (*PeeringServerAddresses) MarshalBinary added in v1.13.2

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringServerAddresses) ProtoMessage added in v1.13.2

func (*PeeringServerAddresses) ProtoMessage()

func (*PeeringServerAddresses) ProtoReflect added in v1.13.2

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

func (*PeeringServerAddresses) Reset added in v1.13.2

func (x *PeeringServerAddresses) Reset()

func (*PeeringServerAddresses) String added in v1.13.2

func (x *PeeringServerAddresses) String() string

func (*PeeringServerAddresses) UnmarshalBinary added in v1.13.2

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.

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) 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 (PeeringState) String

func (x PeeringState) String() string

func (PeeringState) Type

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 (*PeeringTerminateByIDRequest) MarshalBinary

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

MarshalBinary implements encoding.BinaryMarshaler

func (*PeeringTerminateByIDRequest) ProtoMessage

func (*PeeringTerminateByIDRequest) ProtoMessage()

func (*PeeringTerminateByIDRequest) ProtoReflect

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 (*PeeringTerminateByIDResponse) Reset

func (x *PeeringTerminateByIDResponse) Reset()

func (*PeeringTerminateByIDResponse) 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) 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 (*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 (*PeeringTrustBundleDeleteRequest) Reset

func (*PeeringTrustBundleDeleteRequest) 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 (*PeeringTrustBundleDeleteResponse) Reset

func (*PeeringTrustBundleDeleteResponse) 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 (*PeeringTrustBundleWriteRequest) Reset

func (x *PeeringTrustBundleWriteRequest) Reset()

func (*PeeringTrustBundleWriteRequest) 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 (*PeeringTrustBundleWriteResponse) Reset

func (*PeeringTrustBundleWriteResponse) 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 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 (*SecretsWriteRequest) GetExchangeSecret

func (*SecretsWriteRequest) GetGenerateToken

func (*SecretsWriteRequest) GetPeerID

func (x *SecretsWriteRequest) GetPeerID() string

func (*SecretsWriteRequest) GetPromotePending

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 (*SecretsWriteRequest_EstablishRequest) Reset

func (*SecretsWriteRequest_EstablishRequest) 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) ProtoReflect

func (*SecretsWriteRequest_ExchangeSecretRequest) Reset

func (*SecretsWriteRequest_ExchangeSecretRequest) 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) ProtoReflect

func (*SecretsWriteRequest_GenerateTokenRequest) Reset

func (*SecretsWriteRequest_GenerateTokenRequest) 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) ProtoReflect

func (*SecretsWriteRequest_PromotePendingRequest) Reset

func (*SecretsWriteRequest_PromotePendingRequest) String

func (*SecretsWriteRequest_PromotePendingRequest) UnmarshalBinary

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

func (req *TrustBundleListByServiceRequest) RequestDatacenter() string

RequestDatacenter implements structs.RPCInfo

func (*TrustBundleListByServiceRequest) Reset

func (*TrustBundleListByServiceRequest) String

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 (*TrustBundleListByServiceResponse) GetIndex

func (*TrustBundleListByServiceResponse) MarshalBinary

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

MarshalBinary implements encoding.BinaryMarshaler

func (*TrustBundleListByServiceResponse) ProtoMessage

func (*TrustBundleListByServiceResponse) ProtoMessage()

func (*TrustBundleListByServiceResponse) ProtoReflect

func (*TrustBundleListByServiceResponse) Reset

func (*TrustBundleListByServiceResponse) 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 {
	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 (*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) GenerateToken

func (UnimplementedPeeringServiceServer) PeeringDelete

func (UnimplementedPeeringServiceServer) PeeringList

func (UnimplementedPeeringServiceServer) PeeringRead

func (UnimplementedPeeringServiceServer) PeeringWrite

func (UnimplementedPeeringServiceServer) TrustBundleRead

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.

Jump to

Keyboard shortcuts

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