taps

package
v1.9.7 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2020 License: MPL-2.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterTapServer 

func RegisterTapServer(s *grpc.Server, srv TapServer)

func Run 

func Run(ctx context.Context, name string, log MessageLog, tap Tap) error

Types

type MessageLog 

type MessageLog interface {
	Consume(context.Context, string, func(string, *packet.Publish) error) error
}

type PutWaspRecordRequest 

type PutWaspRecordRequest struct {
	WaspRecords          []*WaspRecord `protobuf:"bytes,1,rep,name=WaspRecords,proto3" json:"WaspRecords,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*PutWaspRecordRequest) Descriptor 

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

func (*PutWaspRecordRequest) GetWaspRecords 

func (m *PutWaspRecordRequest) GetWaspRecords() []*WaspRecord

func (*PutWaspRecordRequest) ProtoMessage 

func (*PutWaspRecordRequest) ProtoMessage()

func (*PutWaspRecordRequest) Reset 

func (m *PutWaspRecordRequest) Reset()

func (*PutWaspRecordRequest) String 

func (m *PutWaspRecordRequest) String() string

func (*PutWaspRecordRequest) XXX_DiscardUnknown 

func (m *PutWaspRecordRequest) XXX_DiscardUnknown()

func (*PutWaspRecordRequest) XXX_Marshal 

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

func (*PutWaspRecordRequest) XXX_Merge 

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

func (*PutWaspRecordRequest) XXX_Size 

func (m *PutWaspRecordRequest) XXX_Size() int

func (*PutWaspRecordRequest) XXX_Unmarshal 

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

type PutWaspRecordsResponse 

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

func (*PutWaspRecordsResponse) Descriptor 

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

func (*PutWaspRecordsResponse) ProtoMessage 

func (*PutWaspRecordsResponse) ProtoMessage()

func (*PutWaspRecordsResponse) Reset 

func (m *PutWaspRecordsResponse) Reset()

func (*PutWaspRecordsResponse) String 

func (m *PutWaspRecordsResponse) String() string

func (*PutWaspRecordsResponse) XXX_DiscardUnknown 

func (m *PutWaspRecordsResponse) XXX_DiscardUnknown()

func (*PutWaspRecordsResponse) XXX_Marshal 

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

func (*PutWaspRecordsResponse) XXX_Merge 

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

func (*PutWaspRecordsResponse) XXX_Size 

func (m *PutWaspRecordsResponse) XXX_Size() int

func (*PutWaspRecordsResponse) XXX_Unmarshal 

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

type Tap 

type Tap func(context.Context, string, *packet.Publish) error

func GRPC 

func GRPC(remote *grpc.ClientConn) (Tap, error)

func Syslog 

func Syslog(ctx context.Context, remote string) (Tap, error)

type TapClient 

type TapClient interface {
	PutWaspRecords(ctx context.Context, in *PutWaspRecordRequest, opts ...grpc.CallOption) (*PutWaspRecordsResponse, error)
}

TapClient is the client API for Tap service.

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

func NewTapClient 

func NewTapClient(cc *grpc.ClientConn) TapClient

type TapServer 

type TapServer interface {
	PutWaspRecords(context.Context, *PutWaspRecordRequest) (*PutWaspRecordsResponse, error)
}

TapServer is the server API for Tap service.

type UnimplementedTapServer 

type UnimplementedTapServer struct {
}

UnimplementedTapServer can be embedded to have forward compatible implementations.

func (*UnimplementedTapServer) PutWaspRecords 

func (*UnimplementedTapServer) PutWaspRecords(ctx context.Context, req *PutWaspRecordRequest) (*PutWaspRecordsResponse, error)

type WaspRecord 

type WaspRecord struct {
	Timestamp            int64    `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Topic                []byte   `protobuf:"bytes,2,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Payload              []byte   `protobuf:"bytes,3,opt,name=Payload,proto3" json:"Payload,omitempty"`
	Retained             bool     `protobuf:"varint,4,opt,name=Retained,proto3" json:"Retained,omitempty"`
	Sender               string   `protobuf:"bytes,5,opt,name=Sender,proto3" json:"Sender,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaspRecord) Descriptor 

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

func (*WaspRecord) GetPayload 

func (m *WaspRecord) GetPayload() []byte

func (*WaspRecord) GetRetained added in v1.5.0 

func (m *WaspRecord) GetRetained() bool

func (*WaspRecord) GetSender added in v1.5.0 

func (m *WaspRecord) GetSender() string

func (*WaspRecord) GetTimestamp 

func (m *WaspRecord) GetTimestamp() int64

func (*WaspRecord) GetTopic 

func (m *WaspRecord) GetTopic() []byte

func (*WaspRecord) ProtoMessage 

func (*WaspRecord) ProtoMessage()

func (*WaspRecord) Reset 

func (m *WaspRecord) Reset()

func (*WaspRecord) String 

func (m *WaspRecord) String() string

func (*WaspRecord) XXX_DiscardUnknown 

func (m *WaspRecord) XXX_DiscardUnknown()

func (*WaspRecord) XXX_Marshal 

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

func (*WaspRecord) XXX_Merge 

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

func (*WaspRecord) XXX_Size 

func (m *WaspRecord) XXX_Size() int

func (*WaspRecord) XXX_Unmarshal 

func (m *WaspRecord) 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.