spectrepb

package
v0.39.0 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Direction_name = map[int32]string{
		0: "DIRECTION_UNSPECIFIED",
		1: "DIRECTION_INGRESS",
		2: "DIRECTION_EGRESS",
	}
	Direction_value = map[string]int32{
		"DIRECTION_UNSPECIFIED": 0,
		"DIRECTION_INGRESS":     1,
		"DIRECTION_EGRESS":      2,
	}
)

Enum value maps for Direction.

View Source 
var (
	Quarantine_Kind_name = map[int32]string{
		0: "KIND_UNSPECIFIED",
		1: "KIND_DIVERGENT",
		2: "KIND_UNABLE",
		3: "KIND_UNMATCHED",
		4: "KIND_UNLISTED",
		5: "KIND_CAPACITY",
		6: "KIND_PAIRING",
	}
	Quarantine_Kind_value = map[string]int32{
		"KIND_UNSPECIFIED": 0,
		"KIND_DIVERGENT":   1,
		"KIND_UNABLE":      2,
		"KIND_UNMATCHED":   3,
		"KIND_UNLISTED":    4,
		"KIND_CAPACITY":    5,
		"KIND_PAIRING":     6,
	}
)

Enum value maps for Quarantine_Kind.

View Source 
var File_spectre_v1_spectre_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ClearDivergencesRequest 

type ClearDivergencesRequest struct {
	Service     string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Environment string `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

ClearDivergencesRequest names the service environment whose divergences to remove.

func (*ClearDivergencesRequest) Descriptor deprecated 

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

Deprecated: Use ClearDivergencesRequest.ProtoReflect.Descriptor instead.

func (*ClearDivergencesRequest) GetEnvironment 

func (x *ClearDivergencesRequest) GetEnvironment() string

func (*ClearDivergencesRequest) GetService 

func (x *ClearDivergencesRequest) GetService() string

func (*ClearDivergencesRequest) ProtoMessage 

func (*ClearDivergencesRequest) ProtoMessage()

func (*ClearDivergencesRequest) ProtoReflect 

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

func (*ClearDivergencesRequest) Reset 

func (x *ClearDivergencesRequest) Reset()

func (*ClearDivergencesRequest) String 

func (x *ClearDivergencesRequest) String() string

type ClearDivergencesResponse 

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

func (*ClearDivergencesResponse) Descriptor deprecated 

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

Deprecated: Use ClearDivergencesResponse.ProtoReflect.Descriptor instead.

func (*ClearDivergencesResponse) ProtoMessage 

func (*ClearDivergencesResponse) ProtoMessage()

func (*ClearDivergencesResponse) ProtoReflect 

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

func (*ClearDivergencesResponse) Reset 

func (x *ClearDivergencesResponse) Reset()

func (*ClearDivergencesResponse) String 

func (x *ClearDivergencesResponse) String() string

type Direction 

type Direction int32

Direction names the proxy that carries traffic. 

const (
	Direction_DIRECTION_UNSPECIFIED Direction = 0
	// Requests to the proxied service.
	Direction_DIRECTION_INGRESS Direction = 1
	// Requests from the service to a dependency.
	Direction_DIRECTION_EGRESS Direction = 2
)

func (Direction) Descriptor 

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum 

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor deprecated 

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

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number 

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String 

func (x Direction) String() string

func (Direction) Type 

func (Direction) Type() protoreflect.EnumType

type Divergence 

type Divergence struct {
	Service     string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Environment string `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	// Revision is the commit of the candidate the mirror runs.
	Revision string `protobuf:"bytes,3,opt,name=revision,proto3" json:"revision,omitempty"`
	// Direction is the proxy that quarantined the candidate.
	Direction  Direction   `protobuf:"varint,4,opt,name=direction,proto3,enum=spectre.v1.Direction" json:"direction,omitempty"`
	Quarantine *Quarantine `protobuf:"bytes,5,opt,name=quarantine,proto3" json:"quarantine,omitempty"`
	// contains filtered or unexported fields
}

Divergence is a quarantine of the mirror of one service environment.

func (*Divergence) Descriptor deprecated 

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

Deprecated: Use Divergence.ProtoReflect.Descriptor instead.

func (*Divergence) GetDirection 

func (x *Divergence) GetDirection() Direction

func (*Divergence) GetEnvironment 

func (x *Divergence) GetEnvironment() string

func (*Divergence) GetQuarantine 

func (x *Divergence) GetQuarantine() *Quarantine

func (*Divergence) GetRevision 

func (x *Divergence) GetRevision() string

func (*Divergence) GetService 

func (x *Divergence) GetService() string

func (*Divergence) ProtoMessage 

func (*Divergence) ProtoMessage()

func (*Divergence) ProtoReflect 

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

func (*Divergence) Reset 

func (x *Divergence) Reset()

func (*Divergence) String 

func (x *Divergence) String() string

type ListDivergencesRequest 

type ListDivergencesRequest struct {
	Service     *string `protobuf:"bytes,1,opt,name=service,proto3,oneof" json:"service,omitempty"`
	Environment *string `protobuf:"bytes,2,opt,name=environment,proto3,oneof" json:"environment,omitempty"`
	Revision    *string `protobuf:"bytes,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// Node matches only divergences on routes of that migration state node.
	Node *string `protobuf:"bytes,4,opt,name=node,proto3,oneof" json:"node,omitempty"`
	// contains filtered or unexported fields
}

ListDivergencesRequest filters divergences. An unset filter matches every value.

func (*ListDivergencesRequest) Descriptor deprecated 

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

Deprecated: Use ListDivergencesRequest.ProtoReflect.Descriptor instead.

func (*ListDivergencesRequest) GetEnvironment 

func (x *ListDivergencesRequest) GetEnvironment() string

func (*ListDivergencesRequest) GetNode 

func (x *ListDivergencesRequest) GetNode() string

func (*ListDivergencesRequest) GetRevision 

func (x *ListDivergencesRequest) GetRevision() string

func (*ListDivergencesRequest) GetService 

func (x *ListDivergencesRequest) GetService() string

func (*ListDivergencesRequest) ProtoMessage 

func (*ListDivergencesRequest) ProtoMessage()

func (*ListDivergencesRequest) ProtoReflect 

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

func (*ListDivergencesRequest) Reset 

func (x *ListDivergencesRequest) Reset()

func (*ListDivergencesRequest) String 

func (x *ListDivergencesRequest) String() string

type ListDivergencesResponse 

type ListDivergencesResponse struct {
	Divergences []*Divergence `protobuf:"bytes,1,rep,name=divergences,proto3" json:"divergences,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDivergencesResponse) Descriptor deprecated 

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

Deprecated: Use ListDivergencesResponse.ProtoReflect.Descriptor instead.

func (*ListDivergencesResponse) GetDivergences 

func (x *ListDivergencesResponse) GetDivergences() []*Divergence

func (*ListDivergencesResponse) ProtoMessage 

func (*ListDivergencesResponse) ProtoMessage()

func (*ListDivergencesResponse) ProtoReflect 

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

func (*ListDivergencesResponse) Reset 

func (x *ListDivergencesResponse) Reset()

func (*ListDivergencesResponse) String 

func (x *ListDivergencesResponse) String() string

type Quarantine 

type Quarantine struct {
	Since *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=since,proto3" json:"since,omitempty"`
	Kind  Quarantine_Kind        `protobuf:"varint,2,opt,name=kind,proto3,enum=spectre.v1.Quarantine_Kind" json:"kind,omitempty"`
	// Traffic is absent when no single request caused the quarantine.
	Traffic *Traffic `protobuf:"bytes,3,opt,name=traffic,proto3" json:"traffic,omitempty"`
	// Node is the migration state node that owns an ingress route.
	Node        *string  `protobuf:"bytes,4,opt,name=node,proto3,oneof" json:"node,omitempty"`
	Differences []string `protobuf:"bytes,5,rep,name=differences,proto3" json:"differences,omitempty"`
	Detail      string   `protobuf:"bytes,6,opt,name=detail,proto3" json:"detail,omitempty"`
	// contains filtered or unexported fields
}

Quarantine is why a proxy quarantined the candidate. It never carries payload values.

func (*Quarantine) Descriptor deprecated 

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

Deprecated: Use Quarantine.ProtoReflect.Descriptor instead.

func (*Quarantine) GetDetail 

func (x *Quarantine) GetDetail() string

func (*Quarantine) GetDifferences 

func (x *Quarantine) GetDifferences() []string

func (*Quarantine) GetKind 

func (x *Quarantine) GetKind() Quarantine_Kind

func (*Quarantine) GetNode 

func (x *Quarantine) GetNode() string

func (*Quarantine) GetSince 

func (x *Quarantine) GetSince() *timestamppb.Timestamp

func (*Quarantine) GetTraffic 

func (x *Quarantine) GetTraffic() *Traffic

func (*Quarantine) ProtoMessage 

func (*Quarantine) ProtoMessage()

func (*Quarantine) ProtoReflect 

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

func (*Quarantine) Reset 

func (x *Quarantine) Reset()

func (*Quarantine) String 

func (x *Quarantine) String() string

type QuarantineRequest 

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

func (*QuarantineRequest) Descriptor deprecated 

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

Deprecated: Use QuarantineRequest.ProtoReflect.Descriptor instead.

func (*QuarantineRequest) GetDivergence 

func (x *QuarantineRequest) GetDivergence() *Divergence

func (*QuarantineRequest) ProtoMessage 

func (*QuarantineRequest) ProtoMessage()

func (*QuarantineRequest) ProtoReflect 

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

func (*QuarantineRequest) Reset 

func (x *QuarantineRequest) Reset()

func (*QuarantineRequest) String 

func (x *QuarantineRequest) String() string

type QuarantineResponse 

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

func (*QuarantineResponse) Descriptor deprecated 

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

Deprecated: Use QuarantineResponse.ProtoReflect.Descriptor instead.

func (*QuarantineResponse) ProtoMessage 

func (*QuarantineResponse) ProtoMessage()

func (*QuarantineResponse) ProtoReflect 

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

func (*QuarantineResponse) Reset 

func (x *QuarantineResponse) Reset()

func (*QuarantineResponse) String 

func (x *QuarantineResponse) String() string

type Quarantine_Kind 

type Quarantine_Kind int32

Kind is why the proxy quarantined the candidate. 

const (
	Quarantine_KIND_UNSPECIFIED Quarantine_Kind = 0
	// The candidate's responses differ from the reference's.
	Quarantine_KIND_DIVERGENT Quarantine_Kind = 1
	// The mirror could not compare or replay traffic.
	Quarantine_KIND_UNABLE Quarantine_Kind = 2
	// The candidate made a dependency request the reference did not.
	Quarantine_KIND_UNMATCHED Quarantine_Kind = 3
	// An ingress route is in no node of the migration state.
	Quarantine_KIND_UNLISTED Quarantine_Kind = 4
	// Candidate work exceeded a concurrency or buffer limit.
	Quarantine_KIND_CAPACITY Quarantine_Kind = 5
	// The mirror could not pair candidate and reference traffic.
	Quarantine_KIND_PAIRING Quarantine_Kind = 6
)

func (Quarantine_Kind) Descriptor 

func (Quarantine_Kind) Descriptor() protoreflect.EnumDescriptor

func (Quarantine_Kind) Enum 

func (x Quarantine_Kind) Enum() *Quarantine_Kind

func (Quarantine_Kind) EnumDescriptor deprecated 

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

Deprecated: Use Quarantine_Kind.Descriptor instead.

func (Quarantine_Kind) Number 

func (x Quarantine_Kind) Number() protoreflect.EnumNumber

func (Quarantine_Kind) String 

func (x Quarantine_Kind) String() string

func (Quarantine_Kind) Type 

func (Quarantine_Kind) Type() protoreflect.EnumType

type Traffic 

type Traffic struct {
	Direction Direction `protobuf:"varint,1,opt,name=direction,proto3,enum=spectre.v1.Direction" json:"direction,omitempty"`
	// Protocol is open-ended, because custom binaries may add protocols.
	Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Route    string `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"`
	// contains filtered or unexported fields
}

Traffic identifies the request that caused a quarantine.

func (*Traffic) Descriptor deprecated 

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

Deprecated: Use Traffic.ProtoReflect.Descriptor instead.

func (*Traffic) GetDirection 

func (x *Traffic) GetDirection() Direction

func (*Traffic) GetProtocol 

func (x *Traffic) GetProtocol() string

func (*Traffic) GetRoute 

func (x *Traffic) GetRoute() string

func (*Traffic) ProtoMessage 

func (*Traffic) ProtoMessage()

func (*Traffic) ProtoReflect 

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

func (*Traffic) Reset 

func (x *Traffic) Reset()

func (*Traffic) String 

func (x *Traffic) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.