google_cloud_meshtelemetry_v1alpha1

package module
v0.0.0-...-c643839 Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterMeshEdgesServiceServer 

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

Types

type MeshEdgesServiceClient 

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 

func NewMeshEdgesServiceClient(cc *grpc.ClientConn) MeshEdgesServiceClient

type MeshEdgesServiceServer 

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

MeshEdgesServiceServer is the server API for MeshEdgesService service.

type ReportTrafficAssertionsRequest 

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 

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

func (*ReportTrafficAssertionsRequest) GetMeshUid 

func (m *ReportTrafficAssertionsRequest) GetMeshUid() string

func (*ReportTrafficAssertionsRequest) GetParent 

func (m *ReportTrafficAssertionsRequest) GetParent() string

func (*ReportTrafficAssertionsRequest) GetTimestamp 

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

func (*ReportTrafficAssertionsRequest) GetTrafficAssertions 

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

func (*ReportTrafficAssertionsRequest) ProtoMessage 

func (*ReportTrafficAssertionsRequest) ProtoMessage()

func (*ReportTrafficAssertionsRequest) Reset 

func (m *ReportTrafficAssertionsRequest) Reset()

func (*ReportTrafficAssertionsRequest) String 

func (m *ReportTrafficAssertionsRequest) String() string

func (*ReportTrafficAssertionsRequest) XXX_DiscardUnknown 

func (m *ReportTrafficAssertionsRequest) XXX_DiscardUnknown()

func (*ReportTrafficAssertionsRequest) XXX_Marshal 

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

func (*ReportTrafficAssertionsRequest) XXX_Merge 

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

func (*ReportTrafficAssertionsRequest) XXX_Size 

func (m *ReportTrafficAssertionsRequest) XXX_Size() int

func (*ReportTrafficAssertionsRequest) XXX_Unmarshal 

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

type ReportTrafficAssertionsResponse 

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

func (*ReportTrafficAssertionsResponse) Descriptor 

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

func (*ReportTrafficAssertionsResponse) ProtoMessage 

func (*ReportTrafficAssertionsResponse) ProtoMessage()

func (*ReportTrafficAssertionsResponse) Reset 

func (m *ReportTrafficAssertionsResponse) Reset()

func (*ReportTrafficAssertionsResponse) String 

func (m *ReportTrafficAssertionsResponse) String() string

func (*ReportTrafficAssertionsResponse) XXX_DiscardUnknown 

func (m *ReportTrafficAssertionsResponse) XXX_DiscardUnknown()

func (*ReportTrafficAssertionsResponse) XXX_Marshal 

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

func (*ReportTrafficAssertionsResponse) XXX_Merge 

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

func (*ReportTrafficAssertionsResponse) XXX_Size 

func (m *ReportTrafficAssertionsResponse) XXX_Size() int

func (*ReportTrafficAssertionsResponse) XXX_Unmarshal 

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

type TrafficAssertion 

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 `` /* 137-byte string literal not displayed */
	DestinationServiceName      string                    `` /* 129-byte string literal not displayed */
	DestinationServiceNamespace string                    `` /* 144-byte string literal not displayed */
	XXX_NoUnkeyedLiteral        struct{}                  `json:"-"`
	XXX_unrecognized            []byte                    `json:"-"`
	XXX_sizecache               int32                     `json:"-"`
}

func (*TrafficAssertion) Descriptor 

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

func (*TrafficAssertion) GetDestination 

func (m *TrafficAssertion) GetDestination() *WorkloadInstance

func (*TrafficAssertion) GetDestinationServiceName 

func (m *TrafficAssertion) GetDestinationServiceName() string

func (*TrafficAssertion) GetDestinationServiceNamespace 

func (m *TrafficAssertion) GetDestinationServiceNamespace() string

func (*TrafficAssertion) GetProtocol 

func (m *TrafficAssertion) GetProtocol() TrafficAssertion_Protocol

func (*TrafficAssertion) GetSource 

func (m *TrafficAssertion) GetSource() *WorkloadInstance

func (*TrafficAssertion) ProtoMessage 

func (*TrafficAssertion) ProtoMessage()

func (*TrafficAssertion) Reset 

func (m *TrafficAssertion) Reset()

func (*TrafficAssertion) String 

func (m *TrafficAssertion) String() string

func (*TrafficAssertion) XXX_DiscardUnknown 

func (m *TrafficAssertion) XXX_DiscardUnknown()

func (*TrafficAssertion) XXX_Marshal 

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

func (*TrafficAssertion) XXX_Merge 

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

func (*TrafficAssertion) XXX_Size 

func (m *TrafficAssertion) XXX_Size() int

func (*TrafficAssertion) XXX_Unmarshal 

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

type TrafficAssertion_Protocol 

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 

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

func (TrafficAssertion_Protocol) String 

func (x TrafficAssertion_Protocol) String() string

type UnimplementedMeshEdgesServiceServer 

type UnimplementedMeshEdgesServiceServer struct {
}

UnimplementedMeshEdgesServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMeshEdgesServiceServer) ReportTrafficAssertions 

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

type WorkloadInstance 

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 

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

func (*WorkloadInstance) GetCanonicalRevision 

func (m *WorkloadInstance) GetCanonicalRevision() string

func (*WorkloadInstance) GetCanonicalService 

func (m *WorkloadInstance) GetCanonicalService() string

func (*WorkloadInstance) GetClusterName 

func (m *WorkloadInstance) GetClusterName() string

func (*WorkloadInstance) GetLocation 

func (m *WorkloadInstance) GetLocation() string

func (*WorkloadInstance) GetOwnerUid 

func (m *WorkloadInstance) GetOwnerUid() string

func (*WorkloadInstance) GetUid 

func (m *WorkloadInstance) GetUid() string

func (*WorkloadInstance) GetWorkloadName 

func (m *WorkloadInstance) GetWorkloadName() string

func (*WorkloadInstance) GetWorkloadNamespace 

func (m *WorkloadInstance) GetWorkloadNamespace() string

func (*WorkloadInstance) ProtoMessage 

func (*WorkloadInstance) ProtoMessage()

func (*WorkloadInstance) Reset 

func (m *WorkloadInstance) Reset()

func (*WorkloadInstance) String 

func (m *WorkloadInstance) String() string

func (*WorkloadInstance) XXX_DiscardUnknown 

func (m *WorkloadInstance) XXX_DiscardUnknown()

func (*WorkloadInstance) XXX_Marshal 

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

func (*WorkloadInstance) XXX_Merge 

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

func (*WorkloadInstance) XXX_Size 

func (m *WorkloadInstance) XXX_Size() int

func (*WorkloadInstance) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.