benchtchannelgogoprotobuf

package
v0.0.0-...-6cbfa36 Latest Latest
Warning

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

 Go to latest Published: May 18, 2018 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthNode = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNode   = fmt.Errorf("proto: integer overflow")
)

Functions

func BenchmarkTChannelGogoprotobufFetch 

func BenchmarkTChannelGogoprotobufFetch(
	address string,
	n, connectionsPerHost, concurrency int,
	nextRequest bench.RequestGenerator,
	ready chan<- struct{},
	start <-chan struct{},
	done chan<- []error,
)

BenchmarkTChannelGogoprotobufFetch benchmarks fetching one by one

func BenchmarkTChannelGogoprotobufFetchBatch 

func BenchmarkTChannelGogoprotobufFetchBatch(
	address string,
	n, connectionsPerHost, concurrency, batchLen int,
	nextRequest bench.RequestGenerator,
	ready chan<- struct{},
	start <-chan struct{},
	done chan<- []error,
)

BenchmarkTChannelGogoprotobufFetchBatch benchmarks fetching one by one with a stream

Types

type Close 

type Close func()

Close is a method to call to close a resource or procedure

func StartTestTChannelServer 

func StartTestTChannelServer(address string, opts *tchannel.ChannelOptions) (Close, error)

StartTestTChannelServer starts a test server

type FetchBatchRequest 

type FetchBatchRequest struct {
	StartUnixMs int64    `protobuf:"varint,1,opt,name=startUnixMs,proto3" json:"startUnixMs,omitempty"`
	EndUnixMs   int64    `protobuf:"varint,2,opt,name=endUnixMs,proto3" json:"endUnixMs,omitempty"`
	Ids         []string `protobuf:"bytes,3,rep,name=ids" json:"ids,omitempty"`
}

func (*FetchBatchRequest) Descriptor 

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

func (*FetchBatchRequest) Marshal 

func (m *FetchBatchRequest) Marshal() (data []byte, err error)

func (*FetchBatchRequest) MarshalTo 

func (m *FetchBatchRequest) MarshalTo(data []byte) (int, error)

func (*FetchBatchRequest) ProtoMessage 

func (*FetchBatchRequest) ProtoMessage()

func (*FetchBatchRequest) Reset 

func (m *FetchBatchRequest) Reset()

func (*FetchBatchRequest) Size 

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

func (*FetchBatchRequest) String 

func (m *FetchBatchRequest) String() string

func (*FetchBatchRequest) Unmarshal 

func (m *FetchBatchRequest) Unmarshal(data []byte) error

type FetchBatchResult 

type FetchBatchResult struct {
	Results []*FetchResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}

func (*FetchBatchResult) Descriptor 

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

func (*FetchBatchResult) GetResults 

func (m *FetchBatchResult) GetResults() []*FetchResult

func (*FetchBatchResult) Marshal 

func (m *FetchBatchResult) Marshal() (data []byte, err error)

func (*FetchBatchResult) MarshalTo 

func (m *FetchBatchResult) MarshalTo(data []byte) (int, error)

func (*FetchBatchResult) ProtoMessage 

func (*FetchBatchResult) ProtoMessage()

func (*FetchBatchResult) Reset 

func (m *FetchBatchResult) Reset()

func (*FetchBatchResult) Size 

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

func (*FetchBatchResult) String 

func (m *FetchBatchResult) String() string

func (*FetchBatchResult) Unmarshal 

func (m *FetchBatchResult) Unmarshal(data []byte) error

type FetchRequest 

type FetchRequest struct {
	StartUnixMs int64  `protobuf:"varint,1,opt,name=startUnixMs,proto3" json:"startUnixMs,omitempty"`
	EndUnixMs   int64  `protobuf:"varint,2,opt,name=endUnixMs,proto3" json:"endUnixMs,omitempty"`
	Id          string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
}

func (*FetchRequest) Descriptor 

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

func (*FetchRequest) Marshal 

func (m *FetchRequest) Marshal() (data []byte, err error)

func (*FetchRequest) MarshalTo 

func (m *FetchRequest) MarshalTo(data []byte) (int, error)

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) Reset 

func (m *FetchRequest) Reset()

func (*FetchRequest) Size 

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

func (*FetchRequest) String 

func (m *FetchRequest) String() string

func (*FetchRequest) Unmarshal 

func (m *FetchRequest) Unmarshal(data []byte) error

type FetchResult 

type FetchResult struct {
	Segments []*FetchResult_Segment `protobuf:"bytes,1,rep,name=segments" json:"segments,omitempty"`
}

func (*FetchResult) Descriptor 

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

func (*FetchResult) GetSegments 

func (m *FetchResult) GetSegments() []*FetchResult_Segment

func (*FetchResult) Marshal 

func (m *FetchResult) Marshal() (data []byte, err error)

func (*FetchResult) MarshalTo 

func (m *FetchResult) MarshalTo(data []byte) (int, error)

func (*FetchResult) ProtoMessage 

func (*FetchResult) ProtoMessage()

func (*FetchResult) Reset 

func (m *FetchResult) Reset()

func (*FetchResult) Size 

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

func (*FetchResult) String 

func (m *FetchResult) String() string

func (*FetchResult) Unmarshal 

func (m *FetchResult) Unmarshal(data []byte) error

type FetchResult_Segment 

type FetchResult_Segment struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*FetchResult_Segment) Descriptor 

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

func (*FetchResult_Segment) Marshal 

func (m *FetchResult_Segment) Marshal() (data []byte, err error)

func (*FetchResult_Segment) MarshalTo 

func (m *FetchResult_Segment) MarshalTo(data []byte) (int, error)

func (*FetchResult_Segment) ProtoMessage 

func (*FetchResult_Segment) ProtoMessage()

func (*FetchResult_Segment) Reset 

func (m *FetchResult_Segment) Reset()

func (*FetchResult_Segment) Size 

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

func (*FetchResult_Segment) String 

func (m *FetchResult_Segment) String() string

func (*FetchResult_Segment) Unmarshal 

func (m *FetchResult_Segment) Unmarshal(data []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.