istio: istio.io/istio/pkg/test/framework/components/stackdriver/edges Index | Files

package google_cloud_meshtelemetry_v1alpha1

import "istio.io/istio/pkg/test/framework/components/stackdriver/edges"

Index

Package Files

edges.pb.go

Variables

var TrafficAssertion_Protocol_name = map[int32]string{
    0:  "PROTOCOL_UNSPECIFIED",
    1:  "PROTOCOL_HTTP",
    2:  "PROTOCOL_HTTPS",
    3:  "PROTOCOL_TCP",
    4:  "PROTOCOL_GRPC",
}
var TrafficAssertion_Protocol_value = map[string]int32{
    "PROTOCOL_UNSPECIFIED": 0,
    "PROTOCOL_HTTP":        1,
    "PROTOCOL_HTTPS":       2,
    "PROTOCOL_TCP":         3,
    "PROTOCOL_GRPC":        4,
}

func RegisterMeshEdgesServiceServer Uses

func RegisterMeshEdgesServiceServer(s *grpc.Server, srv MeshEdgesServiceServer)

type MeshEdgesServiceClient Uses

type MeshEdgesServiceClient interface {
    ReportTrafficAssertions(ctx context.Context, in *ReportTrafficAssertionsRequest, opts ...grpc.CallOption) (*ReportTrafficAssertionsResponse, error)
}

MeshEdgesServiceClient is the client API for MeshEdgesService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMeshEdgesServiceClient Uses

func NewMeshEdgesServiceClient(cc *grpc.ClientConn) MeshEdgesServiceClient

type MeshEdgesServiceServer Uses

type MeshEdgesServiceServer interface {
    ReportTrafficAssertions(context.Context, *ReportTrafficAssertionsRequest) (*ReportTrafficAssertionsResponse, error)
}

MeshEdgesServiceServer is the server API for MeshEdgesService service.

type ReportTrafficAssertionsRequest Uses

type ReportTrafficAssertionsRequest struct {
    Parent               string               `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    MeshUid              string               `protobuf:"bytes,2,opt,name=mesh_uid,json=meshUid,proto3" json:"mesh_uid,omitempty"`
    TrafficAssertions    []*TrafficAssertion  `protobuf:"bytes,3,rep,name=traffic_assertions,json=trafficAssertions,proto3" json:"traffic_assertions,omitempty"`
    Timestamp            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

func (*ReportTrafficAssertionsRequest) Descriptor Uses

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

func (*ReportTrafficAssertionsRequest) GetMeshUid Uses

func (m *ReportTrafficAssertionsRequest) GetMeshUid() string

func (*ReportTrafficAssertionsRequest) GetParent Uses

func (m *ReportTrafficAssertionsRequest) GetParent() string

func (*ReportTrafficAssertionsRequest) GetTimestamp Uses

func (m *ReportTrafficAssertionsRequest) GetTimestamp() *timestamp.Timestamp

func (*ReportTrafficAssertionsRequest) GetTrafficAssertions Uses

func (m *ReportTrafficAssertionsRequest) GetTrafficAssertions() []*TrafficAssertion

func (*ReportTrafficAssertionsRequest) ProtoMessage Uses

func (*ReportTrafficAssertionsRequest) ProtoMessage()

func (*ReportTrafficAssertionsRequest) Reset Uses

func (m *ReportTrafficAssertionsRequest) Reset()

func (*ReportTrafficAssertionsRequest) String Uses

func (m *ReportTrafficAssertionsRequest) String() string

func (*ReportTrafficAssertionsRequest) XXX_DiscardUnknown Uses

func (m *ReportTrafficAssertionsRequest) XXX_DiscardUnknown()

func (*ReportTrafficAssertionsRequest) XXX_Marshal Uses

func (m *ReportTrafficAssertionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportTrafficAssertionsRequest) XXX_Merge Uses

func (m *ReportTrafficAssertionsRequest) XXX_Merge(src proto.Message)

func (*ReportTrafficAssertionsRequest) XXX_Size Uses

func (m *ReportTrafficAssertionsRequest) XXX_Size() int

func (*ReportTrafficAssertionsRequest) XXX_Unmarshal Uses

func (m *ReportTrafficAssertionsRequest) XXX_Unmarshal(b []byte) error

type ReportTrafficAssertionsResponse Uses

type ReportTrafficAssertionsResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ReportTrafficAssertionsResponse) Descriptor Uses

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

func (*ReportTrafficAssertionsResponse) ProtoMessage Uses

func (*ReportTrafficAssertionsResponse) ProtoMessage()

func (*ReportTrafficAssertionsResponse) Reset Uses

func (m *ReportTrafficAssertionsResponse) Reset()

func (*ReportTrafficAssertionsResponse) String Uses

func (m *ReportTrafficAssertionsResponse) String() string

func (*ReportTrafficAssertionsResponse) XXX_DiscardUnknown Uses

func (m *ReportTrafficAssertionsResponse) XXX_DiscardUnknown()

func (*ReportTrafficAssertionsResponse) XXX_Marshal Uses

func (m *ReportTrafficAssertionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportTrafficAssertionsResponse) XXX_Merge Uses

func (m *ReportTrafficAssertionsResponse) XXX_Merge(src proto.Message)

func (*ReportTrafficAssertionsResponse) XXX_Size Uses

func (m *ReportTrafficAssertionsResponse) XXX_Size() int

func (*ReportTrafficAssertionsResponse) XXX_Unmarshal Uses

func (m *ReportTrafficAssertionsResponse) XXX_Unmarshal(b []byte) error

type TrafficAssertion Uses

type TrafficAssertion struct {
    Source                      *WorkloadInstance         `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
    Destination                 *WorkloadInstance         `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
    Protocol                    TrafficAssertion_Protocol `protobuf:"varint,3,opt,name=protocol,proto3,enum=google.cloud.meshtelemetry.v1alpha1.TrafficAssertion_Protocol" json:"protocol,omitempty"`
    DestinationServiceName      string                    `protobuf:"bytes,4,opt,name=destination_service_name,json=destinationServiceName,proto3" json:"destination_service_name,omitempty"`
    DestinationServiceNamespace string                    `protobuf:"bytes,5,opt,name=destination_service_namespace,json=destinationServiceNamespace,proto3" json:"destination_service_namespace,omitempty"`
    XXX_NoUnkeyedLiteral        struct{}                  `json:"-"`
    XXX_unrecognized            []byte                    `json:"-"`
    XXX_sizecache               int32                     `json:"-"`
}

func (*TrafficAssertion) Descriptor Uses

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

func (*TrafficAssertion) GetDestination Uses

func (m *TrafficAssertion) GetDestination() *WorkloadInstance

func (*TrafficAssertion) GetDestinationServiceName Uses

func (m *TrafficAssertion) GetDestinationServiceName() string

func (*TrafficAssertion) GetDestinationServiceNamespace Uses

func (m *TrafficAssertion) GetDestinationServiceNamespace() string

func (*TrafficAssertion) GetProtocol Uses

func (m *TrafficAssertion) GetProtocol() TrafficAssertion_Protocol

func (*TrafficAssertion) GetSource Uses

func (m *TrafficAssertion) GetSource() *WorkloadInstance

func (*TrafficAssertion) ProtoMessage Uses

func (*TrafficAssertion) ProtoMessage()

func (*TrafficAssertion) Reset Uses

func (m *TrafficAssertion) Reset()

func (*TrafficAssertion) String Uses

func (m *TrafficAssertion) String() string

func (*TrafficAssertion) XXX_DiscardUnknown Uses

func (m *TrafficAssertion) XXX_DiscardUnknown()

func (*TrafficAssertion) XXX_Marshal Uses

func (m *TrafficAssertion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficAssertion) XXX_Merge Uses

func (m *TrafficAssertion) XXX_Merge(src proto.Message)

func (*TrafficAssertion) XXX_Size Uses

func (m *TrafficAssertion) XXX_Size() int

func (*TrafficAssertion) XXX_Unmarshal Uses

func (m *TrafficAssertion) XXX_Unmarshal(b []byte) error

type TrafficAssertion_Protocol Uses

type TrafficAssertion_Protocol int32
const (
    TrafficAssertion_PROTOCOL_UNSPECIFIED TrafficAssertion_Protocol = 0
    TrafficAssertion_PROTOCOL_HTTP        TrafficAssertion_Protocol = 1
    TrafficAssertion_PROTOCOL_HTTPS       TrafficAssertion_Protocol = 2
    TrafficAssertion_PROTOCOL_TCP         TrafficAssertion_Protocol = 3
    TrafficAssertion_PROTOCOL_GRPC        TrafficAssertion_Protocol = 4
)

func (TrafficAssertion_Protocol) EnumDescriptor Uses

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

func (TrafficAssertion_Protocol) String Uses

func (x TrafficAssertion_Protocol) String() string

type UnimplementedMeshEdgesServiceServer Uses

type UnimplementedMeshEdgesServiceServer struct {
}

UnimplementedMeshEdgesServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMeshEdgesServiceServer) ReportTrafficAssertions Uses

func (*UnimplementedMeshEdgesServiceServer) ReportTrafficAssertions(ctx context.Context, req *ReportTrafficAssertionsRequest) (*ReportTrafficAssertionsResponse, error)

type WorkloadInstance Uses

type WorkloadInstance struct {
    Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
    Location             string   `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
    ClusterName          string   `protobuf:"bytes,3,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    OwnerUid             string   `protobuf:"bytes,4,opt,name=owner_uid,json=ownerUid,proto3" json:"owner_uid,omitempty"`
    WorkloadName         string   `protobuf:"bytes,5,opt,name=workload_name,json=workloadName,proto3" json:"workload_name,omitempty"`
    WorkloadNamespace    string   `protobuf:"bytes,6,opt,name=workload_namespace,json=workloadNamespace,proto3" json:"workload_namespace,omitempty"`
    CanonicalService     string   `protobuf:"bytes,7,opt,name=canonical_service,json=canonicalService,proto3" json:"canonical_service,omitempty"`
    CanonicalRevision    string   `protobuf:"bytes,8,opt,name=canonical_revision,json=canonicalRevision,proto3" json:"canonical_revision,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*WorkloadInstance) Descriptor Uses

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

func (*WorkloadInstance) GetCanonicalRevision Uses

func (m *WorkloadInstance) GetCanonicalRevision() string

func (*WorkloadInstance) GetCanonicalService Uses

func (m *WorkloadInstance) GetCanonicalService() string

func (*WorkloadInstance) GetClusterName Uses

func (m *WorkloadInstance) GetClusterName() string

func (*WorkloadInstance) GetLocation Uses

func (m *WorkloadInstance) GetLocation() string

func (*WorkloadInstance) GetOwnerUid Uses

func (m *WorkloadInstance) GetOwnerUid() string

func (*WorkloadInstance) GetUid Uses

func (m *WorkloadInstance) GetUid() string

func (*WorkloadInstance) GetWorkloadName Uses

func (m *WorkloadInstance) GetWorkloadName() string

func (*WorkloadInstance) GetWorkloadNamespace Uses

func (m *WorkloadInstance) GetWorkloadNamespace() string

func (*WorkloadInstance) ProtoMessage Uses

func (*WorkloadInstance) ProtoMessage()

func (*WorkloadInstance) Reset Uses

func (m *WorkloadInstance) Reset()

func (*WorkloadInstance) String Uses

func (m *WorkloadInstance) String() string

func (*WorkloadInstance) XXX_DiscardUnknown Uses

func (m *WorkloadInstance) XXX_DiscardUnknown()

func (*WorkloadInstance) XXX_Marshal Uses

func (m *WorkloadInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkloadInstance) XXX_Merge Uses

func (m *WorkloadInstance) XXX_Merge(src proto.Message)

func (*WorkloadInstance) XXX_Size Uses

func (m *WorkloadInstance) XXX_Size() int

func (*WorkloadInstance) XXX_Unmarshal Uses

func (m *WorkloadInstance) XXX_Unmarshal(b []byte) error

Package google_cloud_meshtelemetry_v1alpha1 imports 8 packages (graph) and is imported by 2 packages. Updated 2020-08-29. Refresh now. Tools for package owners.