plumbing

Documentation

Overview

Package plumbing is a generated protocol buffer package.

It is generated from these files:

grpc.proto

It has these top-level messages:

EnvelopeData
PushResponse
SubscriptionRequest
Filter
Response
ContainerMetricsRequest
ContainerMetricsResponse
RecentLogsRequest
RecentLogsResponse

Index

• func NewMutualTLSConfig(certFile, keyFile, caCertFile, serverName string) (*tls.Config, error)
• func NewTLSConfig() *tls.Config
• func RegisterDopplerIngestorServer(s *grpc.Server, srv DopplerIngestorServer)
• func RegisterDopplerServer(s *grpc.Server, srv DopplerServer)
• type CASignatureError
  • func (e CASignatureError) Error() string
• type ContainerMetricsRequest
  • func (*ContainerMetricsRequest) Descriptor() ([]byte, []int)
  • func (*ContainerMetricsRequest) ProtoMessage()
  • func (m *ContainerMetricsRequest) Reset()
  • func (m *ContainerMetricsRequest) String() string
• type ContainerMetricsResponse
  • func (*ContainerMetricsResponse) Descriptor() ([]byte, []int)
  • func (*ContainerMetricsResponse) ProtoMessage()
  • func (m *ContainerMetricsResponse) Reset()
  • func (m *ContainerMetricsResponse) String() string
• type DopplerClient
  • func NewDopplerClient(cc *grpc.ClientConn) DopplerClient
• type DopplerIngestorClient
  • func NewDopplerIngestorClient(cc *grpc.ClientConn) DopplerIngestorClient
• type DopplerIngestorServer
• type DopplerIngestor_PusherClient
• type DopplerIngestor_PusherServer
• type DopplerServer
• type Doppler_SubscribeClient
• type Doppler_SubscribeServer
• type EnvelopeData
  • func (*EnvelopeData) Descriptor() ([]byte, []int)
  • func (*EnvelopeData) ProtoMessage()
  • func (m *EnvelopeData) Reset()
  • func (m *EnvelopeData) String() string
• type Filter
  • func (*Filter) Descriptor() ([]byte, []int)
  • func (*Filter) ProtoMessage()
  • func (m *Filter) Reset()
  • func (m *Filter) String() string
• type PushResponse
  • func (*PushResponse) Descriptor() ([]byte, []int)
  • func (*PushResponse) ProtoMessage()
  • func (m *PushResponse) Reset()
  • func (m *PushResponse) String() string
• type RecentLogsRequest
  • func (*RecentLogsRequest) Descriptor() ([]byte, []int)
  • func (*RecentLogsRequest) ProtoMessage()
  • func (m *RecentLogsRequest) Reset()
  • func (m *RecentLogsRequest) String() string
• type RecentLogsResponse
  • func (*RecentLogsResponse) Descriptor() ([]byte, []int)
  • func (*RecentLogsResponse) ProtoMessage()
  • func (m *RecentLogsResponse) Reset()
  • func (m *RecentLogsResponse) String() string
• type Response
  • func (*Response) Descriptor() ([]byte, []int)
  • func (*Response) ProtoMessage()
  • func (m *Response) Reset()
  • func (m *Response) String() string
• type SubscriptionRequest
  • func (*SubscriptionRequest) Descriptor() ([]byte, []int)
  • func (m *SubscriptionRequest) GetFilter() *Filter
  • func (*SubscriptionRequest) ProtoMessage()
  • func (m *SubscriptionRequest) Reset()
  • func (m *SubscriptionRequest) String() string

Functions

func NewMutualTLSConfig

func NewMutualTLSConfig(certFile, keyFile, caCertFile, serverName string) (*tls.Config, error)

NewMutualTLSConfig returns a tls.Config with certs loaded from files and the ServerName set.

func NewTLSConfig

func NewTLSConfig() *tls.Config

NewTLSConfig

func RegisterDopplerIngestorServer

func RegisterDopplerIngestorServer(s *grpc.Server, srv DopplerIngestorServer)

func RegisterDopplerServer

func RegisterDopplerServer(s *grpc.Server, srv DopplerServer)

Types

type CASignatureError

type CASignatureError string

func (CASignatureError) Error

func (e CASignatureError) Error() string

type ContainerMetricsRequest

type ContainerMetricsRequest struct {
	AppID string `protobuf:"bytes,1,opt,name=appID" json:"appID,omitempty"`
}

func (*ContainerMetricsRequest) Descriptor

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

func (*ContainerMetricsRequest) ProtoMessage

func (*ContainerMetricsRequest) ProtoMessage()

func (*ContainerMetricsRequest) Reset

func (m *ContainerMetricsRequest) Reset()

func (*ContainerMetricsRequest) String

func (m *ContainerMetricsRequest) String() string

type ContainerMetricsResponse

type ContainerMetricsResponse struct {
	Payload [][]byte `protobuf:"bytes,1,rep,name=payload,proto3" json:"payload,omitempty"`
}

func (*ContainerMetricsResponse) Descriptor

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

func (*ContainerMetricsResponse) ProtoMessage

func (*ContainerMetricsResponse) ProtoMessage()

func (*ContainerMetricsResponse) Reset

func (m *ContainerMetricsResponse) Reset()

func (*ContainerMetricsResponse) String

func (m *ContainerMetricsResponse) String() string

type DopplerClient

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

func NewDopplerClient

func NewDopplerClient(cc *grpc.ClientConn) DopplerClient

type DopplerIngestorClient

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

func NewDopplerIngestorClient

func NewDopplerIngestorClient(cc *grpc.ClientConn) DopplerIngestorClient

type DopplerIngestorServer

type DopplerIngestorServer interface {
	Pusher(DopplerIngestor_PusherServer) error
}

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
	ContainerMetrics(context.Context, *ContainerMetricsRequest) (*ContainerMetricsResponse, error)
	RecentLogs(context.Context, *RecentLogsRequest) (*RecentLogsResponse, error)
}

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 EnvelopeData

type EnvelopeData struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*EnvelopeData) Descriptor

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

func (*EnvelopeData) ProtoMessage

func (*EnvelopeData) ProtoMessage()

func (*EnvelopeData) Reset

func (m *EnvelopeData) Reset()

func (*EnvelopeData) String

func (m *EnvelopeData) String() string

type Filter

type Filter struct {
	AppID string `protobuf:"bytes,1,opt,name=appID" json:"appID,omitempty"`
}

func (*Filter) Descriptor

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

func (*Filter) ProtoMessage

func (*Filter) ProtoMessage()

func (*Filter) Reset

func (m *Filter) Reset()

func (*Filter) String

func (m *Filter) String() string

type PushResponse

type PushResponse struct {
}

func (*PushResponse) Descriptor

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

func (*PushResponse) ProtoMessage

func (*PushResponse) ProtoMessage()

func (*PushResponse) Reset

func (m *PushResponse) Reset()

func (*PushResponse) String

func (m *PushResponse) String() string

type RecentLogsRequest

type RecentLogsRequest struct {
	AppID string `protobuf:"bytes,1,opt,name=appID" json:"appID,omitempty"`
}

func (*RecentLogsRequest) Descriptor

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

func (*RecentLogsRequest) ProtoMessage

func (*RecentLogsRequest) ProtoMessage()

func (*RecentLogsRequest) Reset

func (m *RecentLogsRequest) Reset()

func (*RecentLogsRequest) String

func (m *RecentLogsRequest) String() string

type RecentLogsResponse

type RecentLogsResponse struct {
	Payload [][]byte `protobuf:"bytes,1,rep,name=payload,proto3" json:"payload,omitempty"`
}

func (*RecentLogsResponse) Descriptor

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

func (*RecentLogsResponse) ProtoMessage

func (*RecentLogsResponse) ProtoMessage()

func (*RecentLogsResponse) Reset

func (m *RecentLogsResponse) Reset()

func (*RecentLogsResponse) String

func (m *RecentLogsResponse) String() string

type Response

type Response struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
}

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

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

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) String

func (m *Response) String() string

type SubscriptionRequest

type SubscriptionRequest struct {
	ShardID string  `protobuf:"bytes,1,opt,name=shardID" json:"shardID,omitempty"`
	Filter  *Filter `protobuf:"bytes,2,opt,name=filter" json:"filter,omitempty"`
}

func (*SubscriptionRequest) Descriptor

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

func (*SubscriptionRequest) GetFilter

func (m *SubscriptionRequest) GetFilter() *Filter

func (*SubscriptionRequest) ProtoMessage

func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) Reset

func (m *SubscriptionRequest) Reset()

func (*SubscriptionRequest) String

func (m *SubscriptionRequest) String() string