stats

package
v0.0.0-...-79c606f Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package stats exposes the grpc API for accessing runtime statistics from a Sif coordinator

Index

Constants

This section is empty.

Variables

View Source 
var File_s_stats_proto protoreflect.FileDescriptor
View Source 
var StatsServerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stats.StatsServerService",
	HandlerType: (*StatsServerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RuntimeStatistics",
			Handler:    _StatsServerService_RuntimeStatistics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "s_stats.proto",
}

StatsServerService_ServiceDesc is the grpc.ServiceDesc for StatsServerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var StatsSourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stats.StatsSourceService",
	HandlerType: (*StatsSourceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ProvideStatistics",
			Handler:    _StatsSourceService_ProvideStatistics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "s_stats.proto",
}

StatsSourceService_ServiceDesc is the grpc.ServiceDesc for StatsSourceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterStatsServerServiceServer 

func RegisterStatsServerServiceServer(s grpc.ServiceRegistrar, srv StatsServerServiceServer)

func RegisterStatsSourceServiceServer 

func RegisterStatsSourceServiceServer(s grpc.ServiceRegistrar, srv StatsSourceServiceServer)

Types

type MClusterStatisticsRequest 

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

func (*MClusterStatisticsRequest) Descriptor deprecated 

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

Deprecated: Use MClusterStatisticsRequest.ProtoReflect.Descriptor instead.

func (*MClusterStatisticsRequest) ProtoMessage 

func (*MClusterStatisticsRequest) ProtoMessage()

func (*MClusterStatisticsRequest) ProtoReflect 

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

func (*MClusterStatisticsRequest) Reset 

func (x *MClusterStatisticsRequest) Reset()

func (*MClusterStatisticsRequest) String 

func (x *MClusterStatisticsRequest) String() string

type MClusterStatisticsResponse 

type MClusterStatisticsResponse struct {
	ClusterStats map[string]*MStatisticsResponse `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MClusterStatisticsResponse) Descriptor deprecated 

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

Deprecated: Use MClusterStatisticsResponse.ProtoReflect.Descriptor instead.

func (*MClusterStatisticsResponse) GetClusterStats 

func (x *MClusterStatisticsResponse) GetClusterStats() map[string]*MStatisticsResponse

func (*MClusterStatisticsResponse) ProtoMessage 

func (*MClusterStatisticsResponse) ProtoMessage()

func (*MClusterStatisticsResponse) ProtoReflect 

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

func (*MClusterStatisticsResponse) Reset 

func (x *MClusterStatisticsResponse) Reset()

func (*MClusterStatisticsResponse) String 

func (x *MClusterStatisticsResponse) String() string

type MStatisticsRequest 

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

func (*MStatisticsRequest) Descriptor deprecated 

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

Deprecated: Use MStatisticsRequest.ProtoReflect.Descriptor instead.

func (*MStatisticsRequest) ProtoMessage 

func (*MStatisticsRequest) ProtoMessage()

func (*MStatisticsRequest) ProtoReflect 

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

func (*MStatisticsRequest) Reset 

func (x *MStatisticsRequest) Reset()

func (*MStatisticsRequest) String 

func (x *MStatisticsRequest) String() string

type MStatisticsResponse 

type MStatisticsResponse struct {
	Started                     bool    `protobuf:"varint,1,opt,name=started,proto3" json:"started,omitempty"`
	Finished                    bool    `protobuf:"varint,2,opt,name=finished,proto3" json:"finished,omitempty"`
	StartTime                   int64   `protobuf:"varint,3,opt,name=startTime,proto3" json:"startTime,omitempty"`
	TotalRuntime                int64   `protobuf:"varint,4,opt,name=totalRuntime,proto3" json:"totalRuntime,omitempty"`
	RowsProcessed               []int64 `protobuf:"varint,5,rep,packed,name=rowsProcessed,proto3" json:"rowsProcessed,omitempty"`
	PartitionsProcessed         []int64 `protobuf:"varint,6,rep,packed,name=partitionsProcessed,proto3" json:"partitionsProcessed,omitempty"`
	RecentPartitionRuntimes     []int64 `protobuf:"varint,7,rep,packed,name=recentPartitionRuntimes,proto3" json:"recentPartitionRuntimes,omitempty"`
	RecentPartitionRuntimesHead int32   `protobuf:"varint,8,opt,name=recentPartitionRuntimesHead,proto3" json:"recentPartitionRuntimesHead,omitempty"`
	StageRuntimes               []int64 `protobuf:"varint,9,rep,packed,name=stageRuntimes,proto3" json:"stageRuntimes,omitempty"`
	TransformPhaseRuntimes      []int64 `protobuf:"varint,10,rep,packed,name=transformPhaseRuntimes,proto3" json:"transformPhaseRuntimes,omitempty"`
	ShufflePhaseRuntimes        []int64 `protobuf:"varint,11,rep,packed,name=shufflePhaseRuntimes,proto3" json:"shufflePhaseRuntimes,omitempty"`
	// contains filtered or unexported fields
}

func (*MStatisticsResponse) Descriptor deprecated 

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

Deprecated: Use MStatisticsResponse.ProtoReflect.Descriptor instead.

func (*MStatisticsResponse) GetFinished 

func (x *MStatisticsResponse) GetFinished() bool

func (*MStatisticsResponse) GetPartitionsProcessed 

func (x *MStatisticsResponse) GetPartitionsProcessed() []int64

func (*MStatisticsResponse) GetRecentPartitionRuntimes 

func (x *MStatisticsResponse) GetRecentPartitionRuntimes() []int64

func (*MStatisticsResponse) GetRecentPartitionRuntimesHead 

func (x *MStatisticsResponse) GetRecentPartitionRuntimesHead() int32

func (*MStatisticsResponse) GetRowsProcessed 

func (x *MStatisticsResponse) GetRowsProcessed() []int64

func (*MStatisticsResponse) GetShufflePhaseRuntimes 

func (x *MStatisticsResponse) GetShufflePhaseRuntimes() []int64

func (*MStatisticsResponse) GetStageRuntimes 

func (x *MStatisticsResponse) GetStageRuntimes() []int64

func (*MStatisticsResponse) GetStartTime 

func (x *MStatisticsResponse) GetStartTime() int64

func (*MStatisticsResponse) GetStarted 

func (x *MStatisticsResponse) GetStarted() bool

func (*MStatisticsResponse) GetTotalRuntime 

func (x *MStatisticsResponse) GetTotalRuntime() int64

func (*MStatisticsResponse) GetTransformPhaseRuntimes 

func (x *MStatisticsResponse) GetTransformPhaseRuntimes() []int64

func (*MStatisticsResponse) ProtoMessage 

func (*MStatisticsResponse) ProtoMessage()

func (*MStatisticsResponse) ProtoReflect 

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

func (*MStatisticsResponse) Reset 

func (x *MStatisticsResponse) Reset()

func (*MStatisticsResponse) String 

func (x *MStatisticsResponse) String() string

type StatsServerServiceClient 

type StatsServerServiceClient interface {
	RuntimeStatistics(ctx context.Context, in *MClusterStatisticsRequest, opts ...grpc.CallOption) (*MClusterStatisticsResponse, error)
}

StatsServerServiceClient is the client API for StatsServerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStatsServerServiceClient 

func NewStatsServerServiceClient(cc grpc.ClientConnInterface) StatsServerServiceClient

type StatsServerServiceServer 

type StatsServerServiceServer interface {
	RuntimeStatistics(context.Context, *MClusterStatisticsRequest) (*MClusterStatisticsResponse, error)
	// contains filtered or unexported methods
}

StatsServerServiceServer is the server API for StatsServerService service. All implementations must embed UnimplementedStatsServerServiceServer for forward compatibility

type StatsSourceServiceClient 

type StatsSourceServiceClient interface {
	ProvideStatistics(ctx context.Context, in *MStatisticsRequest, opts ...grpc.CallOption) (*MStatisticsResponse, error)
}

StatsSourceServiceClient is the client API for StatsSourceService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStatsSourceServiceClient 

func NewStatsSourceServiceClient(cc grpc.ClientConnInterface) StatsSourceServiceClient

type StatsSourceServiceServer 

type StatsSourceServiceServer interface {
	ProvideStatistics(context.Context, *MStatisticsRequest) (*MStatisticsResponse, error)
	// contains filtered or unexported methods
}

StatsSourceServiceServer is the server API for StatsSourceService service. All implementations must embed UnimplementedStatsSourceServiceServer for forward compatibility

type UnimplementedStatsServerServiceServer 

type UnimplementedStatsServerServiceServer struct {
}

UnimplementedStatsServerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStatsServerServiceServer) RuntimeStatistics 

func (UnimplementedStatsServerServiceServer) RuntimeStatistics(context.Context, *MClusterStatisticsRequest) (*MClusterStatisticsResponse, error)

type UnimplementedStatsSourceServiceServer 

type UnimplementedStatsSourceServiceServer struct {
}

UnimplementedStatsSourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStatsSourceServiceServer) ProvideStatistics 

func (UnimplementedStatsSourceServiceServer) ProvideStatistics(context.Context, *MStatisticsRequest) (*MStatisticsResponse, error)

type UnsafeStatsServerServiceServer 

type UnsafeStatsServerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeStatsServerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StatsServerServiceServer will result in compilation errors.

type UnsafeStatsSourceServiceServer 

type UnsafeStatsSourceServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeStatsSourceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StatsSourceServiceServer will result in compilation errors.

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.