proto

Documentation

Index

• Variables
• func RegisterDroptailerServer(s *grpc.Server, srv DroptailerServer)
• type Drop
  • func (*Drop) Descriptor() ([]byte, []int)
  • func (x *Drop) GetFields() map[string]string
  • func (x *Drop) GetTimestamp() *timestamp.Timestamp
  • func (*Drop) ProtoMessage()
  • func (x *Drop) ProtoReflect() protoreflect.Message
  • func (x *Drop) Reset()
  • func (x *Drop) String() string
• type DroptailerClient
  • func NewDroptailerClient(cc grpc.ClientConnInterface) DroptailerClient
• type DroptailerServer
• type UnimplementedDroptailerServer
  • func (*UnimplementedDroptailerServer) Push(context.Context, *Drop) (*Void, error)
• type Void
  • func (*Void) Descriptor() ([]byte, []int)
  • func (*Void) ProtoMessage()
  • func (x *Void) ProtoReflect() protoreflect.Message
  • func (x *Void) Reset()
  • func (x *Void) String() string

Variables

var File_droptailer_proto protoreflect.FileDescriptor

Functions

func RegisterDroptailerServer

func RegisterDroptailerServer(s *grpc.Server, srv DroptailerServer)

Types

type Drop

type Drop struct {
	Timestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Fields    map[string]string    `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Drop) Descriptor

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

Deprecated: Use Drop.ProtoReflect.Descriptor instead.

func (*Drop) GetFields

func (x *Drop) GetFields() map[string]string

func (*Drop) GetTimestamp

func (x *Drop) GetTimestamp() *timestamp.Timestamp

func (*Drop) ProtoMessage

func (*Drop) ProtoMessage()

func (*Drop) ProtoReflect

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

func (*Drop) Reset

func (x *Drop) Reset()

func (*Drop) String

func (x *Drop) String() string

type DroptailerClient

type DroptailerClient interface {
	Push(ctx context.Context, in *Drop, opts ...grpc.CallOption) (*Void, error)
}

DroptailerClient is the client API for Droptailer service.

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

func NewDroptailerClient

func NewDroptailerClient(cc grpc.ClientConnInterface) DroptailerClient

type DroptailerServer

type DroptailerServer interface {
	Push(context.Context, *Drop) (*Void, error)
}

DroptailerServer is the server API for Droptailer service.

type UnimplementedDroptailerServer

type UnimplementedDroptailerServer struct {
}

UnimplementedDroptailerServer can be embedded to have forward compatible implementations.

func (*UnimplementedDroptailerServer) Push

func (*UnimplementedDroptailerServer) Push(context.Context, *Drop) (*Void, error)

type Void

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

func (*Void) Descriptor

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage

func (*Void) ProtoMessage()

func (*Void) ProtoReflect

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

func (*Void) Reset

func (x *Void) Reset()

func (*Void) String

func (x *Void) String() string