v1alpha1

package
v0.0.0-...-2d182f5 Latest Latest
Warning

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

Go to latest
Published: Jul 2, 2018 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package v1alpha1 is a generated protocol buffer package.

This package defines the common, core types used by the Mesh Configuration Protocol.

It is generated from these files:

config/mcp/v1alpha1/envelope.proto
config/mcp/v1alpha1/mcp.proto
config/mcp/v1alpha1/metadata.proto

It has these top-level messages:

Envelope
Client
MeshConfigRequest
MeshConfigResponse
Metadata

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthEnvelope = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEnvelope   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthMcp = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMcp   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterAggregatedMeshConfigServiceServer

func RegisterAggregatedMeshConfigServiceServer(s *grpc.Server, srv AggregatedMeshConfigServiceServer)

Types

type AggregatedMeshConfigServiceClient

type AggregatedMeshConfigServiceClient interface {
	// StreamAggregatedResources provides the ability to carefully
	// sequence updates across multiple resource types. A single stream
	// is used with multiple independent MeshConfigRequest /
	// MeshConfigResponses sequences multiplexed via the type URL.
	StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedMeshConfigService_StreamAggregatedResourcesClient, error)
}

func NewAggregatedMeshConfigServiceClient

func NewAggregatedMeshConfigServiceClient(cc *grpc.ClientConn) AggregatedMeshConfigServiceClient

type AggregatedMeshConfigServiceServer

type AggregatedMeshConfigServiceServer interface {
	// StreamAggregatedResources provides the ability to carefully
	// sequence updates across multiple resource types. A single stream
	// is used with multiple independent MeshConfigRequest /
	// MeshConfigResponses sequences multiplexed via the type URL.
	StreamAggregatedResources(AggregatedMeshConfigService_StreamAggregatedResourcesServer) error
}

type AggregatedMeshConfigService_StreamAggregatedResourcesClient

type AggregatedMeshConfigService_StreamAggregatedResourcesClient interface {
	Send(*MeshConfigRequest) error
	Recv() (*MeshConfigResponse, error)
	grpc.ClientStream
}

type AggregatedMeshConfigService_StreamAggregatedResourcesServer

type AggregatedMeshConfigService_StreamAggregatedResourcesServer interface {
	Send(*MeshConfigResponse) error
	Recv() (*MeshConfigRequest, error)
	grpc.ServerStream
}

type Client

type Client struct {
	// An opaque identifier for the MCP client.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Opaque metadata extending the client identifier.
	Metadata *google_protobuf2.Struct `protobuf:"bytes,2,opt,name=metadata" json:"metadata,omitempty"`
}

Identifies a specific MCP client instance. The client identifier is presented to the management server, which may use this identifier to distinguish per client configuration for serving. This information is not authoriative. Authoritative identity should come from the underlying transport layer (e.g. rpc credentials).

func (*Client) Descriptor

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

func (*Client) Equal

func (this *Client) Equal(that interface{}) bool

func (*Client) GetId

func (m *Client) GetId() string

func (*Client) GetMetadata

func (m *Client) GetMetadata() *google_protobuf2.Struct

func (*Client) Marshal

func (m *Client) Marshal() (dAtA []byte, err error)

func (*Client) MarshalTo

func (m *Client) MarshalTo(dAtA []byte) (int, error)

func (*Client) ProtoMessage

func (*Client) ProtoMessage()

func (*Client) Reset

func (m *Client) Reset()

func (*Client) Size

func (m *Client) Size() (n int)

func (*Client) String

func (m *Client) String() string

func (*Client) Unmarshal

func (m *Client) Unmarshal(dAtA []byte) error

type Envelope

type Envelope struct {
	// Common metadata describing the resource.
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	// The resource itself.
	Resource *google_protobuf.Any `protobuf:"bytes,2,opt,name=resource" json:"resource,omitempty"`
}

Envelope for a configuration resource as transferred via the Mesh Configuration Protocol. Each envelope is made up of common metadata, and a type-specific resource payload.

func (*Envelope) Descriptor

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

func (*Envelope) Equal

func (this *Envelope) Equal(that interface{}) bool

func (*Envelope) GetMetadata

func (m *Envelope) GetMetadata() *Metadata

func (*Envelope) GetResource

func (m *Envelope) GetResource() *google_protobuf.Any

func (*Envelope) Marshal

func (m *Envelope) Marshal() (dAtA []byte, err error)

func (*Envelope) MarshalTo

func (m *Envelope) MarshalTo(dAtA []byte) (int, error)

func (*Envelope) ProtoMessage

func (*Envelope) ProtoMessage()

func (*Envelope) Reset

func (m *Envelope) Reset()

func (*Envelope) Size

func (m *Envelope) Size() (n int)

func (*Envelope) String

func (m *Envelope) String() string

func (*Envelope) Unmarshal

func (m *Envelope) Unmarshal(dAtA []byte) error

type MeshConfigRequest

type MeshConfigRequest struct {
	// The version_info provided in the request messages will be the
	// version_info received with the most recent successfully processed
	// response or empty on the first request. It is expected that no
	// new request is sent after a response is received until the client
	// instance is ready to ACK/NACK the new configuration. ACK/NACK
	// takes place by returning the new API config version as applied or
	// the previous API config version respectively. Each type_url (see
	// below) has an independent version associated with it.
	VersionInfo string `protobuf:"bytes,1,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
	// The client making the request.
	Client *Client `protobuf:"bytes,2,opt,name=client" json:"client,omitempty"`
	// Type of the resource that is being requested, e.g.
	// "type.googleapis.com/istio.io.networking.v1alpha3.VirtualService".
	TypeUrl string `protobuf:"bytes,3,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"`
	// The nonce corresponding to MeshConfigResponse being
	// ACK/NACKed. See above discussion on version_info and the
	// MeshConfigResponse nonce comment. This may be empty if no nonce is
	// available, e.g. at startup.
	ResponseNonce string `protobuf:"bytes,4,opt,name=response_nonce,json=responseNonce,proto3" json:"response_nonce,omitempty"`
	// This is populated when the previous MeshConfigResponse failed to
	// update configuration. The *message* field in *error_details*
	// provides the client internal exception related to the failure. It
	// is only intended for consumption during manual debugging, the
	// string provided is not guaranteed to be stable across client
	// versions.
	ErrorDetail *google_rpc.Status `protobuf:"bytes,5,opt,name=error_detail,json=errorDetail" json:"error_detail,omitempty"`
}

A MeshConfigRequest requests a set of versioned resources of the same type for a given client.

func (*MeshConfigRequest) Descriptor

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

func (*MeshConfigRequest) Equal

func (this *MeshConfigRequest) Equal(that interface{}) bool

func (*MeshConfigRequest) GetClient

func (m *MeshConfigRequest) GetClient() *Client

func (*MeshConfigRequest) GetErrorDetail

func (m *MeshConfigRequest) GetErrorDetail() *google_rpc.Status

func (*MeshConfigRequest) GetResponseNonce

func (m *MeshConfigRequest) GetResponseNonce() string

func (*MeshConfigRequest) GetTypeUrl

func (m *MeshConfigRequest) GetTypeUrl() string

func (*MeshConfigRequest) GetVersionInfo

func (m *MeshConfigRequest) GetVersionInfo() string

func (*MeshConfigRequest) Marshal

func (m *MeshConfigRequest) Marshal() (dAtA []byte, err error)

func (*MeshConfigRequest) MarshalTo

func (m *MeshConfigRequest) MarshalTo(dAtA []byte) (int, error)

func (*MeshConfigRequest) ProtoMessage

func (*MeshConfigRequest) ProtoMessage()

func (*MeshConfigRequest) Reset

func (m *MeshConfigRequest) Reset()

func (*MeshConfigRequest) Size

func (m *MeshConfigRequest) Size() (n int)

func (*MeshConfigRequest) String

func (m *MeshConfigRequest) String() string

func (*MeshConfigRequest) Unmarshal

func (m *MeshConfigRequest) Unmarshal(dAtA []byte) error

type MeshConfigResponse

type MeshConfigResponse struct {
	// The version of the response data.
	VersionInfo string `protobuf:"bytes,1,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
	// The response resources wrapped in the common MCP *Envelope*
	// message.
	Envelopes []Envelope `protobuf:"bytes,2,rep,name=envelopes" json:"envelopes"`
	// Type URL for resources wrapped in the provided envelope(s). This
	// must be consistent with the type_url in the wrapper messages if
	// envelopes is non-empty.
	TypeUrl string `protobuf:"bytes,3,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"`
	// The nonce provides a way to explicitly ack a specific
	// MeshConfigResponse in a following MeshConfigRequest. Additional
	// messages may have been sent by client to the management server for
	// the previous version on the stream prior to this
	// MeshConfigResponse, that were unprocessed at response send
	// time. The nonce allows the management server to ignore any
	// further MeshConfigRequests for the previous version until a
	// MeshConfigRequest bearing the nonce.
	Nonce string `protobuf:"bytes,4,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

A MeshConfigResponse delivers a set of versioned resources of the same type in response to a MeshConfigRequest.

func (*MeshConfigResponse) Descriptor

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

func (*MeshConfigResponse) Equal

func (this *MeshConfigResponse) Equal(that interface{}) bool

func (*MeshConfigResponse) GetEnvelopes

func (m *MeshConfigResponse) GetEnvelopes() []Envelope

func (*MeshConfigResponse) GetNonce

func (m *MeshConfigResponse) GetNonce() string

func (*MeshConfigResponse) GetTypeUrl

func (m *MeshConfigResponse) GetTypeUrl() string

func (*MeshConfigResponse) GetVersionInfo

func (m *MeshConfigResponse) GetVersionInfo() string

func (*MeshConfigResponse) Marshal

func (m *MeshConfigResponse) Marshal() (dAtA []byte, err error)

func (*MeshConfigResponse) MarshalTo

func (m *MeshConfigResponse) MarshalTo(dAtA []byte) (int, error)

func (*MeshConfigResponse) ProtoMessage

func (*MeshConfigResponse) ProtoMessage()

func (*MeshConfigResponse) Reset

func (m *MeshConfigResponse) Reset()

func (*MeshConfigResponse) Size

func (m *MeshConfigResponse) Size() (n int)

func (*MeshConfigResponse) String

func (m *MeshConfigResponse) String() string

func (*MeshConfigResponse) Unmarshal

func (m *MeshConfigResponse) Unmarshal(dAtA []byte) error

type Metadata

type Metadata struct {
	// The name of the resource. It is unique within the context of a resource type and the origin server of
	// the resource. The resource type is identified by the TypeUrl of the resource field of the Envelope
	// message.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

Metadata information that all resources within the Mesh Configuration Protocol must have.

func (*Metadata) Descriptor

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

func (*Metadata) Equal

func (this *Metadata) Equal(that interface{}) bool

func (*Metadata) GetName

func (m *Metadata) GetName() string

func (*Metadata) Marshal

func (m *Metadata) Marshal() (dAtA []byte, err error)

func (*Metadata) MarshalTo

func (m *Metadata) MarshalTo(dAtA []byte) (int, error)

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) Reset

func (m *Metadata) Reset()

func (*Metadata) Size

func (m *Metadata) Size() (n int)

func (*Metadata) String

func (m *Metadata) String() string

func (*Metadata) Unmarshal

func (m *Metadata) Unmarshal(dAtA []byte) error

Jump to

Keyboard shortcuts

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