taps

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

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:"-"`
}

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

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

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

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

type UnimplementedTapServer struct {
}

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:"-"`
}