dogstatsd

Documentation

Index

• Constants
• Variables
• func RegisterDogstatsdGRPCServer(s *grpc.Server, srv DogstatsdGRPCServer)
• type DogstatsdGRPCClient
  • func NewDogstatsdGRPCClient(cc *grpc.ClientConn) DogstatsdGRPCClient
• type DogstatsdGRPCServer
• type DogstatsdPacket
  • func (*DogstatsdPacket) Descriptor() ([]byte, []int)
  • func (m *DogstatsdPacket) GetPacketBytes() []byte
  • func (m *DogstatsdPacket) Marshal() (dAtA []byte, err error)
  • func (m *DogstatsdPacket) MarshalTo(dAtA []byte) (int, error)
  • func (*DogstatsdPacket) ProtoMessage()
  • func (m *DogstatsdPacket) Reset()
  • func (m *DogstatsdPacket) Size() (n int)
  • func (m *DogstatsdPacket) String() string
  • func (m *DogstatsdPacket) Unmarshal(dAtA []byte) error
  • func (m *DogstatsdPacket) XXX_DiscardUnknown()
  • func (m *DogstatsdPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DogstatsdPacket) XXX_Merge(src proto.Message)
  • func (m *DogstatsdPacket) XXX_Size() int
  • func (m *DogstatsdPacket) XXX_Unmarshal(b []byte) error
• type Empty
  • func (*Empty) Descriptor() ([]byte, []int)
  • func (m *Empty) Marshal() (dAtA []byte, err error)
  • func (m *Empty) MarshalTo(dAtA []byte) (int, error)
  • func (*Empty) ProtoMessage()
  • func (m *Empty) Reset()
  • func (m *Empty) Size() (n int)
  • func (m *Empty) String() string
  • func (m *Empty) Unmarshal(dAtA []byte) error
  • func (m *Empty) XXX_DiscardUnknown()
  • func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Empty) XXX_Merge(src proto.Message)
  • func (m *Empty) XXX_Size() int
  • func (m *Empty) XXX_Unmarshal(b []byte) error

Constants

const EventAggregationKeyTagKey = "vdogstatsd_ak"

EventAggregationKeyTagKey is a tag key used to conduct the aggregation key of an event to a sink

const EventAlertTypeTagKey = "vdogstatsd_at"

EventAlertTypeTagKey is a tag key used to conduct the alert type of an event to a sink

const EventHostnameTagKey = "vdogstatsd_hostname"

EventHostnameTagKey is a tag key used to conduct the hostname of an event to a sink

const EventIdentifierKey = "vdogstatsd_ev"

EventIdentifierKey is a tag key used to conduct the event identifier of an event to a sink

const EventPriorityTagKey = "vdogstatsd_pri"

EventPriorityTagKey is a tag key used to conduct the priority of an event to a sink

const EventSourceTypeTagKey = "vdogstatsd_st"

EventSourceTypeTagKey is a tag key used to conduct the source type of an event to a sink

Variables

var (
	ErrInvalidLengthGrpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGrpc   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterDogstatsdGRPCServer

func RegisterDogstatsdGRPCServer(s *grpc.Server, srv DogstatsdGRPCServer)

Types

type DogstatsdGRPCClient

type DogstatsdGRPCClient interface {
	SendPacket(ctx context.Context, in *DogstatsdPacket, opts ...grpc.CallOption) (*Empty, error)
}

DogstatsdGRPCClient is the client API for DogstatsdGRPC service.

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

func NewDogstatsdGRPCClient

func NewDogstatsdGRPCClient(cc *grpc.ClientConn) DogstatsdGRPCClient

type DogstatsdGRPCServer

type DogstatsdGRPCServer interface {
	SendPacket(context.Context, *DogstatsdPacket) (*Empty, error)
}

DogstatsdGRPCServer is the server API for DogstatsdGRPC service.

type DogstatsdPacket

type DogstatsdPacket struct {
	PacketBytes []byte `protobuf:"bytes,1,opt,name=packetBytes,proto3" json:"packetBytes,omitempty"`
}

func (*DogstatsdPacket) Descriptor

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

func (*DogstatsdPacket) GetPacketBytes

func (m *DogstatsdPacket) GetPacketBytes() []byte

func (*DogstatsdPacket) Marshal

func (m *DogstatsdPacket) Marshal() (dAtA []byte, err error)

func (*DogstatsdPacket) MarshalTo

func (m *DogstatsdPacket) MarshalTo(dAtA []byte) (int, error)

func (*DogstatsdPacket) ProtoMessage

func (*DogstatsdPacket) ProtoMessage()

func (*DogstatsdPacket) Reset

func (m *DogstatsdPacket) Reset()

func (*DogstatsdPacket) Size

func (m *DogstatsdPacket) Size() (n int)

func (*DogstatsdPacket) String

func (m *DogstatsdPacket) String() string

func (*DogstatsdPacket) Unmarshal

func (m *DogstatsdPacket) Unmarshal(dAtA []byte) error

func (*DogstatsdPacket) XXX_DiscardUnknown

func (m *DogstatsdPacket) XXX_DiscardUnknown()

func (*DogstatsdPacket) XXX_Marshal

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

func (*DogstatsdPacket) XXX_Merge

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

func (*DogstatsdPacket) XXX_Size

func (m *DogstatsdPacket) XXX_Size() int

func (*DogstatsdPacket) XXX_Unmarshal

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

type Empty

type Empty struct {
}

func (*Empty) Descriptor

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

func (*Empty) Marshal

func (m *Empty) Marshal() (dAtA []byte, err error)

func (*Empty) MarshalTo

func (m *Empty) MarshalTo(dAtA []byte) (int, error)

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) Size

func (m *Empty) Size() (n int)

func (*Empty) String

func (m *Empty) String() string

func (*Empty) Unmarshal

func (m *Empty) Unmarshal(dAtA []byte) error

func (*Empty) XXX_DiscardUnknown

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal

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

func (*Empty) XXX_Merge

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

func (*Empty) XXX_Size

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal

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