plumbing

package
v0.0.0-...-96cdf77 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DopplerIngestor_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plumbing.DopplerIngestor",
	HandlerType: (*DopplerIngestorServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Pusher",
			Handler:       _DopplerIngestor_Pusher_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "loggregator-agent-release/src/pkg/plumbing/doppler.proto",
}

DopplerIngestor_ServiceDesc is the grpc.ServiceDesc for DopplerIngestor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Doppler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plumbing.Doppler",
	HandlerType: (*DopplerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ContainerMetrics",
			Handler:    _Doppler_ContainerMetrics_Handler,
		},
		{
			MethodName: "RecentLogs",
			Handler:    _Doppler_RecentLogs_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _Doppler_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "BatchSubscribe",
			Handler:       _Doppler_BatchSubscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "loggregator-agent-release/src/pkg/plumbing/doppler.proto",
}

Doppler_ServiceDesc is the grpc.ServiceDesc for Doppler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_loggregator_agent_release_src_pkg_plumbing_doppler_proto protoreflect.FileDescriptor

Functions

func NewClientCredentials 

func NewClientCredentials(
	certFile string,
	keyFile string,
	caCertFile string,
	serverName string,
) (credentials.TransportCredentials, error)

NewClientCredentials returns gRPC credentials for dialing.

func NewServerCredentials 

func NewServerCredentials(
	certFile string,
	keyFile string,
	caCertFile string,
	opts ...ConfigOption,
) (credentials.TransportCredentials, error)

NewServerCredentials returns gRPC credentials for a server.

func NewTLSHTTPClient 

func NewTLSHTTPClient(cert, key, ca, commonName string, disableKeepAlives bool) *http.Client

func RegisterDopplerIngestorServer 

func RegisterDopplerIngestorServer(s grpc.ServiceRegistrar, srv DopplerIngestorServer)

func RegisterDopplerServer 

func RegisterDopplerServer(s grpc.ServiceRegistrar, srv DopplerServer)

Types

type BatchResponse 

type BatchResponse struct {
	Payload [][]byte `protobuf:"bytes,1,rep,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchResponse) Descriptor deprecated 

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

Deprecated: Use BatchResponse.ProtoReflect.Descriptor instead.

func (*BatchResponse) GetPayload 

func (x *BatchResponse) GetPayload() [][]byte

func (*BatchResponse) ProtoMessage 

func (*BatchResponse) ProtoMessage()

func (*BatchResponse) ProtoReflect 

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

func (*BatchResponse) Reset 

func (x *BatchResponse) Reset()

func (*BatchResponse) String 

func (x *BatchResponse) String() string

type ConfigOption 

type ConfigOption func(*tls.Config)

ConfigOption is used when configuring a new tls.Config.

func WithCipherSuites 

func WithCipherSuites(ciphers []string) ConfigOption

WithCipherSuites is used to override the default cipher suites.

type ContainerMetricsRequest 

type ContainerMetricsRequest struct {
	AppID string `protobuf:"bytes,1,opt,name=appID,proto3" json:"appID,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerMetricsRequest) Descriptor deprecated 

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

Deprecated: Use ContainerMetricsRequest.ProtoReflect.Descriptor instead.

func (*ContainerMetricsRequest) GetAppID 

func (x *ContainerMetricsRequest) GetAppID() string

func (*ContainerMetricsRequest) ProtoMessage 

func (*ContainerMetricsRequest) ProtoMessage()

func (*ContainerMetricsRequest) ProtoReflect 

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

func (*ContainerMetricsRequest) Reset 

func (x *ContainerMetricsRequest) Reset()

func (*ContainerMetricsRequest) String 

func (x *ContainerMetricsRequest) String() string

type ContainerMetricsResponse 

type ContainerMetricsResponse struct {
	Payload [][]byte `protobuf:"bytes,1,rep,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerMetricsResponse) Descriptor deprecated 

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

Deprecated: Use ContainerMetricsResponse.ProtoReflect.Descriptor instead.

func (*ContainerMetricsResponse) GetPayload 

func (x *ContainerMetricsResponse) GetPayload() [][]byte

func (*ContainerMetricsResponse) ProtoMessage 

func (*ContainerMetricsResponse) ProtoMessage()

func (*ContainerMetricsResponse) ProtoReflect 

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

func (*ContainerMetricsResponse) Reset 

func (x *ContainerMetricsResponse) Reset()

func (*ContainerMetricsResponse) String 

func (x *ContainerMetricsResponse) String() string

type DopplerClient 

type DopplerClient interface {
	Subscribe(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (Doppler_SubscribeClient, error)
	BatchSubscribe(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (Doppler_BatchSubscribeClient, error)
	ContainerMetrics(ctx context.Context, in *ContainerMetricsRequest, opts ...grpc.CallOption) (*ContainerMetricsResponse, error)
	RecentLogs(ctx context.Context, in *RecentLogsRequest, opts ...grpc.CallOption) (*RecentLogsResponse, error)
}

DopplerClient is the client API for Doppler 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.

func NewDopplerClient 

func NewDopplerClient(cc grpc.ClientConnInterface) DopplerClient

type DopplerIngestorClient 

type DopplerIngestorClient interface {
	Pusher(ctx context.Context, opts ...grpc.CallOption) (DopplerIngestor_PusherClient, error)
}

DopplerIngestorClient is the client API for DopplerIngestor 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.

func NewDopplerIngestorClient 

func NewDopplerIngestorClient(cc grpc.ClientConnInterface) DopplerIngestorClient

type DopplerIngestorServer 

type DopplerIngestorServer interface {
	Pusher(DopplerIngestor_PusherServer) error
	// contains filtered or unexported methods
}

DopplerIngestorServer is the server API for DopplerIngestor service. All implementations must embed UnimplementedDopplerIngestorServer for forward compatibility

type DopplerIngestor_PusherClient 

type DopplerIngestor_PusherClient interface {
	Send(*EnvelopeData) error
	CloseAndRecv() (*PushResponse, error)
	grpc.ClientStream
}

type DopplerIngestor_PusherServer 

type DopplerIngestor_PusherServer interface {
	SendAndClose(*PushResponse) error
	Recv() (*EnvelopeData, error)
	grpc.ServerStream
}

type DopplerServer 

type DopplerServer interface {
	Subscribe(*SubscriptionRequest, Doppler_SubscribeServer) error
	BatchSubscribe(*SubscriptionRequest, Doppler_BatchSubscribeServer) error
	ContainerMetrics(context.Context, *ContainerMetricsRequest) (*ContainerMetricsResponse, error)
	RecentLogs(context.Context, *RecentLogsRequest) (*RecentLogsResponse, error)
	// contains filtered or unexported methods
}

DopplerServer is the server API for Doppler service. All implementations must embed UnimplementedDopplerServer for forward compatibility

type Doppler_BatchSubscribeClient 

type Doppler_BatchSubscribeClient interface {
	Recv() (*BatchResponse, error)
	grpc.ClientStream
}

type Doppler_BatchSubscribeServer 

type Doppler_BatchSubscribeServer interface {
	Send(*BatchResponse) error
	grpc.ServerStream
}

type Doppler_SubscribeClient 

type Doppler_SubscribeClient interface {
	Recv() (*Response, error)
	grpc.ClientStream
}

type Doppler_SubscribeServer 

type Doppler_SubscribeServer interface {
	Send(*Response) error
	grpc.ServerStream
}

type EnvelopeAverager 

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

EnvelopeAverager implements google.golang.org/grpc/stats.Handler and keeps track of the average envelope size emitted by a grpc client. It should be constructed with NewEnvelopeAverager.

Note: Track is on a very "hot" path. Care should be taken while altering any algorithms, and performance must be considered.

func NewEnvelopeAverager 

func NewEnvelopeAverager() *EnvelopeAverager

NewEnvelopeAverager creates a new EnvelopeAverager.

func (*EnvelopeAverager) Start 

func (a *EnvelopeAverager) Start(interval time.Duration, f func(average float64))

Start invokes the given callback with the average envelope size of the past interval.

func (*EnvelopeAverager) Track 

func (a *EnvelopeAverager) Track(count, size int)

Track takes the given envelope size (in bytes) to use in the current average calculation. It can be called by several go-routines.

type EnvelopeData 

type EnvelopeData struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvelopeData) Descriptor deprecated 

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

Deprecated: Use EnvelopeData.ProtoReflect.Descriptor instead.

func (*EnvelopeData) GetPayload 

func (x *EnvelopeData) GetPayload() []byte

func (*EnvelopeData) ProtoMessage 

func (*EnvelopeData) ProtoMessage()

func (*EnvelopeData) ProtoReflect 

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

func (*EnvelopeData) Reset 

func (x *EnvelopeData) Reset()

func (*EnvelopeData) String 

func (x *EnvelopeData) String() string

type Filter 

type Filter struct {
	AppID string `protobuf:"bytes,1,opt,name=appID,proto3" json:"appID,omitempty"`
	// Types that are assignable to Message:
	//	*Filter_Log
	//	*Filter_Metric
	Message isFilter_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetAppID 

func (x *Filter) GetAppID() string

func (*Filter) GetLog 

func (x *Filter) GetLog() *LogFilter

func (*Filter) GetMessage 

func (m *Filter) GetMessage() isFilter_Message

func (*Filter) GetMetric 

func (x *Filter) GetMetric() *MetricFilter

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type Filter_Log 

type Filter_Log struct {
	Log *LogFilter `protobuf:"bytes,2,opt,name=log,proto3,oneof"`
}

type Filter_Metric 

type Filter_Metric struct {
	Metric *MetricFilter `protobuf:"bytes,3,opt,name=metric,proto3,oneof"`
}

type LogFilter 

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

func (*LogFilter) Descriptor deprecated 

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

Deprecated: Use LogFilter.ProtoReflect.Descriptor instead.

func (*LogFilter) ProtoMessage 

func (*LogFilter) ProtoMessage()

func (*LogFilter) ProtoReflect 

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

func (*LogFilter) Reset 

func (x *LogFilter) Reset()

func (*LogFilter) String 

func (x *LogFilter) String() string

type LogWriter 

type LogWriter struct {
}

func (LogWriter) Write 

func (writer LogWriter) Write(bytes []byte) (int, error)

type MetricFilter 

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

func (*MetricFilter) Descriptor deprecated 

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

Deprecated: Use MetricFilter.ProtoReflect.Descriptor instead.

func (*MetricFilter) ProtoMessage 

func (*MetricFilter) ProtoMessage()

func (*MetricFilter) ProtoReflect 

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

func (*MetricFilter) Reset 

func (x *MetricFilter) Reset()

func (*MetricFilter) String 

func (x *MetricFilter) String() string

type PushResponse 

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

func (*PushResponse) Descriptor deprecated 

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

Deprecated: Use PushResponse.ProtoReflect.Descriptor instead.

func (*PushResponse) ProtoMessage 

func (*PushResponse) ProtoMessage()

func (*PushResponse) ProtoReflect 

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

func (*PushResponse) Reset 

func (x *PushResponse) Reset()

func (*PushResponse) String 

func (x *PushResponse) String() string

type RecentLogsRequest 

type RecentLogsRequest struct {
	AppID string `protobuf:"bytes,1,opt,name=appID,proto3" json:"appID,omitempty"`
	// contains filtered or unexported fields
}

func (*RecentLogsRequest) Descriptor deprecated 

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

Deprecated: Use RecentLogsRequest.ProtoReflect.Descriptor instead.

func (*RecentLogsRequest) GetAppID 

func (x *RecentLogsRequest) GetAppID() string

func (*RecentLogsRequest) ProtoMessage 

func (*RecentLogsRequest) ProtoMessage()

func (*RecentLogsRequest) ProtoReflect 

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

func (*RecentLogsRequest) Reset 

func (x *RecentLogsRequest) Reset()

func (*RecentLogsRequest) String 

func (x *RecentLogsRequest) String() string

type RecentLogsResponse 

type RecentLogsResponse struct {
	Payload [][]byte `protobuf:"bytes,1,rep,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*RecentLogsResponse) Descriptor deprecated 

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

Deprecated: Use RecentLogsResponse.ProtoReflect.Descriptor instead.

func (*RecentLogsResponse) GetPayload 

func (x *RecentLogsResponse) GetPayload() [][]byte

func (*RecentLogsResponse) ProtoMessage 

func (*RecentLogsResponse) ProtoMessage()

func (*RecentLogsResponse) ProtoReflect 

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

func (*RecentLogsResponse) Reset 

func (x *RecentLogsResponse) Reset()

func (*RecentLogsResponse) String 

func (x *RecentLogsResponse) String() string

type Response 

type Response struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

Note: Ideally this would be EnvelopeData but for the time being we do not want to pay the cost of planning an upgrade path for this to be renamed.

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetPayload 

func (x *Response) GetPayload() []byte

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type SubscriptionRequest 

type SubscriptionRequest struct {
	ShardID string  `protobuf:"bytes,1,opt,name=shardID,proto3" json:"shardID,omitempty"`
	Filter  *Filter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use SubscriptionRequest.ProtoReflect.Descriptor instead.

func (*SubscriptionRequest) GetFilter 

func (x *SubscriptionRequest) GetFilter() *Filter

func (*SubscriptionRequest) GetShardID 

func (x *SubscriptionRequest) GetShardID() string

func (*SubscriptionRequest) ProtoMessage 

func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) ProtoReflect 

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

func (*SubscriptionRequest) Reset 

func (x *SubscriptionRequest) Reset()

func (*SubscriptionRequest) String 

func (x *SubscriptionRequest) String() string

type UnimplementedDopplerIngestorServer 

type UnimplementedDopplerIngestorServer struct {
}

UnimplementedDopplerIngestorServer must be embedded to have forward compatible implementations.

func (UnimplementedDopplerIngestorServer) Pusher 

func (UnimplementedDopplerIngestorServer) Pusher(DopplerIngestor_PusherServer) error

type UnimplementedDopplerServer 

type UnimplementedDopplerServer struct {
}

UnimplementedDopplerServer must be embedded to have forward compatible implementations.

func (UnimplementedDopplerServer) BatchSubscribe 

func (UnimplementedDopplerServer) BatchSubscribe(*SubscriptionRequest, Doppler_BatchSubscribeServer) error

func (UnimplementedDopplerServer) ContainerMetrics 

func (UnimplementedDopplerServer) ContainerMetrics(context.Context, *ContainerMetricsRequest) (*ContainerMetricsResponse, error)

func (UnimplementedDopplerServer) RecentLogs 

func (UnimplementedDopplerServer) RecentLogs(context.Context, *RecentLogsRequest) (*RecentLogsResponse, error)

func (UnimplementedDopplerServer) Subscribe 

func (UnimplementedDopplerServer) Subscribe(*SubscriptionRequest, Doppler_SubscribeServer) error

type UnsafeDopplerIngestorServer 

type UnsafeDopplerIngestorServer interface {
	// contains filtered or unexported methods
}

UnsafeDopplerIngestorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DopplerIngestorServer will result in compilation errors.

type UnsafeDopplerServer 

type UnsafeDopplerServer interface {
	// contains filtered or unexported methods
}

UnsafeDopplerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DopplerServer will result in compilation errors.

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.