Help us shape the future of Go! Take the 2026 Go Developer Survey

logproto

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2019 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLogproto = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogproto   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Direction_name = map[int32]string{
	0: "FORWARD",
	1: "BACKWARD",
}
View Source 
var Direction_value = map[string]int32{
	"FORWARD":  0,
	"BACKWARD": 1,
}

Functions

func RegisterPusherServer 

func RegisterPusherServer(s *grpc.Server, srv PusherServer)

func RegisterQuerierServer 

func RegisterQuerierServer(s *grpc.Server, srv QuerierServer)

Types

type Direction 

type Direction int32
const (
	FORWARD  Direction = 0
	BACKWARD Direction = 1
)

func (Direction) EnumDescriptor 

func (Direction) EnumDescriptor() ([]byte, []int)

func (Direction) String 

func (x Direction) String() string

type DroppedStream added in v0.2.0 

type DroppedStream struct {
	From   time.Time `protobuf:"bytes,1,opt,name=from,proto3,stdtime" json:"from"`
	To     time.Time `protobuf:"bytes,2,opt,name=to,proto3,stdtime" json:"to"`
	Labels string    `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"`
}

func (*DroppedStream) Descriptor added in v0.2.0 

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

func (*DroppedStream) Equal added in v0.2.0 

func (this *DroppedStream) Equal(that interface{}) bool

func (*DroppedStream) GetFrom added in v0.2.0 

func (m *DroppedStream) GetFrom() time.Time

func (*DroppedStream) GetLabels added in v0.2.0 

func (m *DroppedStream) GetLabels() string

func (*DroppedStream) GetTo added in v0.2.0 

func (m *DroppedStream) GetTo() time.Time

func (*DroppedStream) GoString added in v0.2.0 

func (this *DroppedStream) GoString() string

func (*DroppedStream) Marshal added in v0.2.0 

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

func (*DroppedStream) MarshalTo added in v0.2.0 

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

func (*DroppedStream) ProtoMessage added in v0.2.0 

func (*DroppedStream) ProtoMessage()

func (*DroppedStream) Reset added in v0.2.0 

func (m *DroppedStream) Reset()

func (*DroppedStream) Size added in v0.2.0 

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

func (*DroppedStream) String added in v0.2.0 

func (this *DroppedStream) String() string

func (*DroppedStream) Unmarshal added in v0.2.0 

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

func (*DroppedStream) XXX_DiscardUnknown added in v0.2.0 

func (m *DroppedStream) XXX_DiscardUnknown()

func (*DroppedStream) XXX_Marshal added in v0.2.0 

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

func (*DroppedStream) XXX_Merge added in v0.2.0 

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

func (*DroppedStream) XXX_Size added in v0.2.0 

func (m *DroppedStream) XXX_Size() int

func (*DroppedStream) XXX_Unmarshal added in v0.2.0 

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

type Entry 

type Entry struct {
	Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,proto3,stdtime" json:"ts"`
	Line      string    `protobuf:"bytes,2,opt,name=line,proto3" json:"line"`
}

func (*Entry) Descriptor 

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

func (*Entry) Equal 

func (this *Entry) Equal(that interface{}) bool

func (*Entry) GetLine 

func (m *Entry) GetLine() string

func (*Entry) GetTimestamp 

func (m *Entry) GetTimestamp() time.Time

func (*Entry) GoString 

func (this *Entry) GoString() string

func (*Entry) Marshal 

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

func (*Entry) MarshalTo 

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

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) Size 

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

func (*Entry) String 

func (this *Entry) String() string

func (*Entry) Unmarshal 

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

func (*Entry) XXX_DiscardUnknown 

func (m *Entry) XXX_DiscardUnknown()

func (*Entry) XXX_Marshal 

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

func (*Entry) XXX_Merge 

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

func (*Entry) XXX_Size 

func (m *Entry) XXX_Size() int

func (*Entry) XXX_Unmarshal 

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

type LabelRequest 

type LabelRequest struct {
	Name   string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Values bool       `protobuf:"varint,2,opt,name=values,proto3" json:"values,omitempty"`
	Start  *time.Time `protobuf:"bytes,3,opt,name=start,proto3,stdtime" json:"start,omitempty"`
	End    *time.Time `protobuf:"bytes,4,opt,name=end,proto3,stdtime" json:"end,omitempty"`
}

func (*LabelRequest) Descriptor 

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

func (*LabelRequest) Equal 

func (this *LabelRequest) Equal(that interface{}) bool

func (*LabelRequest) GetEnd added in v0.2.0 

func (m *LabelRequest) GetEnd() *time.Time

func (*LabelRequest) GetName 

func (m *LabelRequest) GetName() string

func (*LabelRequest) GetStart added in v0.2.0 

func (m *LabelRequest) GetStart() *time.Time

func (*LabelRequest) GetValues 

func (m *LabelRequest) GetValues() bool

func (*LabelRequest) GoString 

func (this *LabelRequest) GoString() string

func (*LabelRequest) Marshal 

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

func (*LabelRequest) MarshalTo 

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

func (*LabelRequest) ProtoMessage 

func (*LabelRequest) ProtoMessage()

func (*LabelRequest) Reset 

func (m *LabelRequest) Reset()

func (*LabelRequest) Size 

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

func (*LabelRequest) String 

func (this *LabelRequest) String() string

func (*LabelRequest) Unmarshal 

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

func (*LabelRequest) XXX_DiscardUnknown 

func (m *LabelRequest) XXX_DiscardUnknown()

func (*LabelRequest) XXX_Marshal 

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

func (*LabelRequest) XXX_Merge 

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

func (*LabelRequest) XXX_Size 

func (m *LabelRequest) XXX_Size() int

func (*LabelRequest) XXX_Unmarshal 

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

type LabelResponse 

type LabelResponse struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

func (*LabelResponse) Descriptor 

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

func (*LabelResponse) Equal 

func (this *LabelResponse) Equal(that interface{}) bool

func (*LabelResponse) GetValues 

func (m *LabelResponse) GetValues() []string

func (*LabelResponse) GoString 

func (this *LabelResponse) GoString() string

func (*LabelResponse) Marshal 

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

func (*LabelResponse) MarshalTo 

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

func (*LabelResponse) ProtoMessage 

func (*LabelResponse) ProtoMessage()

func (*LabelResponse) Reset 

func (m *LabelResponse) Reset()

func (*LabelResponse) Size 

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

func (*LabelResponse) String 

func (this *LabelResponse) String() string

func (*LabelResponse) Unmarshal 

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

func (*LabelResponse) XXX_DiscardUnknown 

func (m *LabelResponse) XXX_DiscardUnknown()

func (*LabelResponse) XXX_Marshal 

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

func (*LabelResponse) XXX_Merge 

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

func (*LabelResponse) XXX_Size 

func (m *LabelResponse) XXX_Size() int

func (*LabelResponse) XXX_Unmarshal 

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

type PushRequest 

type PushRequest struct {
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams"`
}

func (*PushRequest) Descriptor 

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

func (*PushRequest) Equal 

func (this *PushRequest) Equal(that interface{}) bool

func (*PushRequest) GetStreams 

func (m *PushRequest) GetStreams() []*Stream

func (*PushRequest) GoString 

func (this *PushRequest) GoString() string

func (*PushRequest) Marshal 

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

func (*PushRequest) MarshalTo 

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

func (*PushRequest) ProtoMessage 

func (*PushRequest) ProtoMessage()

func (*PushRequest) Reset 

func (m *PushRequest) Reset()

func (*PushRequest) Size 

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

func (*PushRequest) String 

func (this *PushRequest) String() string

func (*PushRequest) Unmarshal 

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

func (*PushRequest) XXX_DiscardUnknown 

func (m *PushRequest) XXX_DiscardUnknown()

func (*PushRequest) XXX_Marshal 

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

func (*PushRequest) XXX_Merge 

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

func (*PushRequest) XXX_Size 

func (m *PushRequest) XXX_Size() int

func (*PushRequest) XXX_Unmarshal 

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

type PushResponse 

type PushResponse struct {
}

func (*PushResponse) Descriptor 

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

func (*PushResponse) Equal 

func (this *PushResponse) Equal(that interface{}) bool

func (*PushResponse) GoString 

func (this *PushResponse) GoString() string

func (*PushResponse) Marshal 

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

func (*PushResponse) MarshalTo 

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

func (*PushResponse) ProtoMessage 

func (*PushResponse) ProtoMessage()

func (*PushResponse) Reset 

func (m *PushResponse) Reset()

func (*PushResponse) Size 

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

func (*PushResponse) String 

func (this *PushResponse) String() string

func (*PushResponse) Unmarshal 

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

func (*PushResponse) XXX_DiscardUnknown 

func (m *PushResponse) XXX_DiscardUnknown()

func (*PushResponse) XXX_Marshal 

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

func (*PushResponse) XXX_Merge 

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

func (*PushResponse) XXX_Size 

func (m *PushResponse) XXX_Size() int

func (*PushResponse) XXX_Unmarshal 

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

type PusherClient 

type PusherClient interface {
	Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error)
}

PusherClient is the client API for Pusher service.

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

func NewPusherClient 

func NewPusherClient(cc *grpc.ClientConn) PusherClient

type PusherServer 

type PusherServer interface {
	Push(context.Context, *PushRequest) (*PushResponse, error)
}

PusherServer is the server API for Pusher service.

type QuerierClient 

type QuerierClient interface {
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Querier_QueryClient, error)
	Label(ctx context.Context, in *LabelRequest, opts ...grpc.CallOption) (*LabelResponse, error)
	Tail(ctx context.Context, in *TailRequest, opts ...grpc.CallOption) (Querier_TailClient, error)
}

QuerierClient is the client API for Querier service.

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

func NewQuerierClient 

func NewQuerierClient(cc *grpc.ClientConn) QuerierClient

type QuerierServer 

type QuerierServer interface {
	Query(*QueryRequest, Querier_QueryServer) error
	Label(context.Context, *LabelRequest) (*LabelResponse, error)
	Tail(*TailRequest, Querier_TailServer) error
}

QuerierServer is the server API for Querier service.

type Querier_QueryClient 

type Querier_QueryClient interface {
	Recv() (*QueryResponse, error)
	grpc.ClientStream
}

type Querier_QueryServer 

type Querier_QueryServer interface {
	Send(*QueryResponse) error
	grpc.ServerStream
}

type Querier_TailClient added in v0.2.0 

type Querier_TailClient interface {
	Recv() (*TailResponse, error)
	grpc.ClientStream
}

type Querier_TailServer added in v0.2.0 

type Querier_TailServer interface {
	Send(*TailResponse) error
	grpc.ServerStream
}

type QueryRequest 

type QueryRequest struct {
	Query     string    `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Limit     uint32    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Start     time.Time `protobuf:"bytes,3,opt,name=start,proto3,stdtime" json:"start"`
	End       time.Time `protobuf:"bytes,4,opt,name=end,proto3,stdtime" json:"end"`
	Direction Direction `protobuf:"varint,5,opt,name=direction,proto3,enum=logproto.Direction" json:"direction,omitempty"`
	Regex     string    `protobuf:"bytes,6,opt,name=regex,proto3" json:"regex,omitempty"`
}

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) Equal 

func (this *QueryRequest) Equal(that interface{}) bool

func (*QueryRequest) GetDirection 

func (m *QueryRequest) GetDirection() Direction

func (*QueryRequest) GetEnd 

func (m *QueryRequest) GetEnd() time.Time

func (*QueryRequest) GetLimit 

func (m *QueryRequest) GetLimit() uint32

func (*QueryRequest) GetQuery 

func (m *QueryRequest) GetQuery() string

func (*QueryRequest) GetRegex 

func (m *QueryRequest) GetRegex() string

func (*QueryRequest) GetStart 

func (m *QueryRequest) GetStart() time.Time

func (*QueryRequest) GoString 

func (this *QueryRequest) GoString() string

func (*QueryRequest) Marshal 

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

func (*QueryRequest) MarshalTo 

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

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) Size 

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

func (*QueryRequest) String 

func (this *QueryRequest) String() string

func (*QueryRequest) Unmarshal 

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

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

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

func (*QueryRequest) XXX_Merge 

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

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

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

type QueryResponse 

type QueryResponse struct {
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
}

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) Equal 

func (this *QueryResponse) Equal(that interface{}) bool

func (*QueryResponse) GetStreams 

func (m *QueryResponse) GetStreams() []*Stream

func (*QueryResponse) GoString 

func (this *QueryResponse) GoString() string

func (*QueryResponse) Marshal 

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

func (*QueryResponse) MarshalTo 

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

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) Size 

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

func (*QueryResponse) String 

func (this *QueryResponse) String() string

func (*QueryResponse) Unmarshal 

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

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

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

func (*QueryResponse) XXX_Merge 

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

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

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

type Stream 

type Stream struct {
	Labels  string  `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels"`
	Entries []Entry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries"`
}

func (*Stream) Descriptor 

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

func (*Stream) Equal 

func (this *Stream) Equal(that interface{}) bool

func (*Stream) GetEntries 

func (m *Stream) GetEntries() []Entry

func (*Stream) GetLabels 

func (m *Stream) GetLabels() string

func (*Stream) GoString 

func (this *Stream) GoString() string

func (*Stream) Marshal 

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

func (*Stream) MarshalTo 

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

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) Size 

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

func (*Stream) String 

func (this *Stream) String() string

func (*Stream) Unmarshal 

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

func (*Stream) XXX_DiscardUnknown 

func (m *Stream) XXX_DiscardUnknown()

func (*Stream) XXX_Marshal 

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

func (*Stream) XXX_Merge 

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

func (*Stream) XXX_Size 

func (m *Stream) XXX_Size() int

func (*Stream) XXX_Unmarshal 

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

type TailRequest added in v0.2.0 

type TailRequest struct {
	Query    string    `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Regex    string    `protobuf:"bytes,2,opt,name=regex,proto3" json:"regex,omitempty"`
	DelayFor uint32    `protobuf:"varint,3,opt,name=delayFor,proto3" json:"delayFor,omitempty"`
	Limit    uint32    `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	Start    time.Time `protobuf:"bytes,5,opt,name=start,proto3,stdtime" json:"start"`
}

func (*TailRequest) Descriptor added in v0.2.0 

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

func (*TailRequest) Equal added in v0.2.0 

func (this *TailRequest) Equal(that interface{}) bool

func (*TailRequest) GetDelayFor added in v0.2.0 

func (m *TailRequest) GetDelayFor() uint32

func (*TailRequest) GetLimit added in v0.2.0 

func (m *TailRequest) GetLimit() uint32

func (*TailRequest) GetQuery added in v0.2.0 

func (m *TailRequest) GetQuery() string

func (*TailRequest) GetRegex added in v0.2.0 

func (m *TailRequest) GetRegex() string

func (*TailRequest) GetStart added in v0.2.0 

func (m *TailRequest) GetStart() time.Time

func (*TailRequest) GoString added in v0.2.0 

func (this *TailRequest) GoString() string

func (*TailRequest) Marshal added in v0.2.0 

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

func (*TailRequest) MarshalTo added in v0.2.0 

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

func (*TailRequest) ProtoMessage added in v0.2.0 

func (*TailRequest) ProtoMessage()

func (*TailRequest) Reset added in v0.2.0 

func (m *TailRequest) Reset()

func (*TailRequest) Size added in v0.2.0 

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

func (*TailRequest) String added in v0.2.0 

func (this *TailRequest) String() string

func (*TailRequest) Unmarshal added in v0.2.0 

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

func (*TailRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *TailRequest) XXX_DiscardUnknown()

func (*TailRequest) XXX_Marshal added in v0.2.0 

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

func (*TailRequest) XXX_Merge added in v0.2.0 

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

func (*TailRequest) XXX_Size added in v0.2.0 

func (m *TailRequest) XXX_Size() int

func (*TailRequest) XXX_Unmarshal added in v0.2.0 

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

type TailResponse added in v0.2.0 

type TailResponse struct {
	Stream         *Stream          `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	DroppedStreams []*DroppedStream `protobuf:"bytes,2,rep,name=droppedStreams,proto3" json:"droppedStreams,omitempty"`
}

func (*TailResponse) Descriptor added in v0.2.0 

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

func (*TailResponse) Equal added in v0.2.0 

func (this *TailResponse) Equal(that interface{}) bool

func (*TailResponse) GetDroppedStreams added in v0.2.0 

func (m *TailResponse) GetDroppedStreams() []*DroppedStream

func (*TailResponse) GetStream added in v0.2.0 

func (m *TailResponse) GetStream() *Stream

func (*TailResponse) GoString added in v0.2.0 

func (this *TailResponse) GoString() string

func (*TailResponse) Marshal added in v0.2.0 

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

func (*TailResponse) MarshalTo added in v0.2.0 

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

func (*TailResponse) ProtoMessage added in v0.2.0 

func (*TailResponse) ProtoMessage()

func (*TailResponse) Reset added in v0.2.0 

func (m *TailResponse) Reset()

func (*TailResponse) Size added in v0.2.0 

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

func (*TailResponse) String added in v0.2.0 

func (this *TailResponse) String() string

func (*TailResponse) Unmarshal added in v0.2.0 

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

func (*TailResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *TailResponse) XXX_DiscardUnknown()

func (*TailResponse) XXX_Marshal added in v0.2.0 

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

func (*TailResponse) XXX_Merge added in v0.2.0 

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

func (*TailResponse) XXX_Size added in v0.2.0 

func (m *TailResponse) XXX_Size() int

func (*TailResponse) XXX_Unmarshal added in v0.2.0 

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

type UnimplementedPusherServer added in v0.2.0 

type UnimplementedPusherServer struct {
}

UnimplementedPusherServer can be embedded to have forward compatible implementations.

func (*UnimplementedPusherServer) Push added in v0.2.0 

func (*UnimplementedPusherServer) Push(ctx context.Context, req *PushRequest) (*PushResponse, error)

type UnimplementedQuerierServer added in v0.2.0 

type UnimplementedQuerierServer struct {
}

UnimplementedQuerierServer can be embedded to have forward compatible implementations.

func (*UnimplementedQuerierServer) Label added in v0.2.0 

func (*UnimplementedQuerierServer) Label(ctx context.Context, req *LabelRequest) (*LabelResponse, error)

func (*UnimplementedQuerierServer) Query added in v0.2.0 

func (*UnimplementedQuerierServer) Query(req *QueryRequest, srv Querier_QueryServer) error

func (*UnimplementedQuerierServer) Tail added in v0.2.0 

func (*UnimplementedQuerierServer) Tail(req *TailRequest, srv Querier_TailServer) 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.