iscc

package
v0.0.0-...-a9d0937 Latest Latest
Warning

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

Go to latest
Published: Apr 10, 2024 License: Apache-2.0 Imports: 12 Imported by: 3

Documentation

Index

Constants

View Source
const (
	InitialSizeClassCache_GetPreviousExecutionStats_FullMethodName    = "/buildbarn.iscc.InitialSizeClassCache/GetPreviousExecutionStats"
	InitialSizeClassCache_UpdatePreviousExecutionStats_FullMethodName = "/buildbarn.iscc.InitialSizeClassCache/UpdatePreviousExecutionStats"
)

Variables

View Source
var File_pkg_proto_iscc_iscc_proto protoreflect.FileDescriptor
View Source
var InitialSizeClassCache_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "buildbarn.iscc.InitialSizeClassCache",
	HandlerType: (*InitialSizeClassCacheServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetPreviousExecutionStats",
			Handler:    _InitialSizeClassCache_GetPreviousExecutionStats_Handler,
		},
		{
			MethodName: "UpdatePreviousExecutionStats",
			Handler:    _InitialSizeClassCache_UpdatePreviousExecutionStats_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/proto/iscc/iscc.proto",
}

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

Functions

func RegisterInitialSizeClassCacheServer

func RegisterInitialSizeClassCacheServer(s grpc.ServiceRegistrar, srv InitialSizeClassCacheServer)

Types

type GetPreviousExecutionStatsRequest

type GetPreviousExecutionStatsRequest struct {
	InstanceName        string                  `protobuf:"bytes,1,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	ReducedActionDigest *v2.Digest              `protobuf:"bytes,2,opt,name=reduced_action_digest,json=reducedActionDigest,proto3" json:"reduced_action_digest,omitempty"`
	DigestFunction      v2.DigestFunction_Value `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetPreviousExecutionStatsRequest) Descriptor deprecated

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

Deprecated: Use GetPreviousExecutionStatsRequest.ProtoReflect.Descriptor instead.

func (*GetPreviousExecutionStatsRequest) GetDigestFunction

func (*GetPreviousExecutionStatsRequest) GetInstanceName

func (x *GetPreviousExecutionStatsRequest) GetInstanceName() string

func (*GetPreviousExecutionStatsRequest) GetReducedActionDigest

func (x *GetPreviousExecutionStatsRequest) GetReducedActionDigest() *v2.Digest

func (*GetPreviousExecutionStatsRequest) ProtoMessage

func (*GetPreviousExecutionStatsRequest) ProtoMessage()

func (*GetPreviousExecutionStatsRequest) ProtoReflect

func (*GetPreviousExecutionStatsRequest) Reset

func (*GetPreviousExecutionStatsRequest) String

type InitialSizeClassCacheClient

type InitialSizeClassCacheClient interface {
	GetPreviousExecutionStats(ctx context.Context, in *GetPreviousExecutionStatsRequest, opts ...grpc.CallOption) (*PreviousExecutionStats, error)
	UpdatePreviousExecutionStats(ctx context.Context, in *UpdatePreviousExecutionStatsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

InitialSizeClassCacheClient is the client API for InitialSizeClassCache 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.

type InitialSizeClassCacheServer

type InitialSizeClassCacheServer interface {
	GetPreviousExecutionStats(context.Context, *GetPreviousExecutionStatsRequest) (*PreviousExecutionStats, error)
	UpdatePreviousExecutionStats(context.Context, *UpdatePreviousExecutionStatsRequest) (*emptypb.Empty, error)
}

InitialSizeClassCacheServer is the server API for InitialSizeClassCache service. All implementations should embed UnimplementedInitialSizeClassCacheServer for forward compatibility

type PerSizeClassStats

type PerSizeClassStats struct {
	PreviousExecutions         []*PreviousExecution `protobuf:"bytes,1,rep,name=previous_executions,json=previousExecutions,proto3" json:"previous_executions,omitempty"`
	InitialPageRankProbability float64              `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PerSizeClassStats) Descriptor deprecated

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

Deprecated: Use PerSizeClassStats.ProtoReflect.Descriptor instead.

func (*PerSizeClassStats) GetInitialPageRankProbability

func (x *PerSizeClassStats) GetInitialPageRankProbability() float64

func (*PerSizeClassStats) GetPreviousExecutions

func (x *PerSizeClassStats) GetPreviousExecutions() []*PreviousExecution

func (*PerSizeClassStats) ProtoMessage

func (*PerSizeClassStats) ProtoMessage()

func (*PerSizeClassStats) ProtoReflect

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

func (*PerSizeClassStats) Reset

func (x *PerSizeClassStats) Reset()

func (*PerSizeClassStats) String

func (x *PerSizeClassStats) String() string

type PreviousExecution

type PreviousExecution struct {

	// Types that are assignable to Outcome:
	//
	//	*PreviousExecution_Failed
	//	*PreviousExecution_TimedOut
	//	*PreviousExecution_Succeeded
	Outcome isPreviousExecution_Outcome `protobuf_oneof:"outcome"`
	// contains filtered or unexported fields
}

func (*PreviousExecution) Descriptor deprecated

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

Deprecated: Use PreviousExecution.ProtoReflect.Descriptor instead.

func (*PreviousExecution) GetFailed

func (x *PreviousExecution) GetFailed() *emptypb.Empty

func (*PreviousExecution) GetOutcome

func (m *PreviousExecution) GetOutcome() isPreviousExecution_Outcome

func (*PreviousExecution) GetSucceeded

func (x *PreviousExecution) GetSucceeded() *durationpb.Duration

func (*PreviousExecution) GetTimedOut

func (x *PreviousExecution) GetTimedOut() *durationpb.Duration

func (*PreviousExecution) ProtoMessage

func (*PreviousExecution) ProtoMessage()

func (*PreviousExecution) ProtoReflect

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

func (*PreviousExecution) Reset

func (x *PreviousExecution) Reset()

func (*PreviousExecution) String

func (x *PreviousExecution) String() string

type PreviousExecutionStats

type PreviousExecutionStats struct {
	SizeClasses     map[uint32]*PerSizeClassStats `` /* 183-byte string literal not displayed */
	LastSeenFailure *timestamppb.Timestamp        `protobuf:"bytes,2,opt,name=last_seen_failure,json=lastSeenFailure,proto3" json:"last_seen_failure,omitempty"`
	// contains filtered or unexported fields
}

func (*PreviousExecutionStats) Descriptor deprecated

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

Deprecated: Use PreviousExecutionStats.ProtoReflect.Descriptor instead.

func (*PreviousExecutionStats) GetLastSeenFailure

func (x *PreviousExecutionStats) GetLastSeenFailure() *timestamppb.Timestamp

func (*PreviousExecutionStats) GetSizeClasses

func (x *PreviousExecutionStats) GetSizeClasses() map[uint32]*PerSizeClassStats

func (*PreviousExecutionStats) ProtoMessage

func (*PreviousExecutionStats) ProtoMessage()

func (*PreviousExecutionStats) ProtoReflect

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

func (*PreviousExecutionStats) Reset

func (x *PreviousExecutionStats) Reset()

func (*PreviousExecutionStats) String

func (x *PreviousExecutionStats) String() string

type PreviousExecution_Failed

type PreviousExecution_Failed struct {
	Failed *emptypb.Empty `protobuf:"bytes,1,opt,name=failed,proto3,oneof"`
}

type PreviousExecution_Succeeded

type PreviousExecution_Succeeded struct {
	Succeeded *durationpb.Duration `protobuf:"bytes,3,opt,name=succeeded,proto3,oneof"`
}

type PreviousExecution_TimedOut

type PreviousExecution_TimedOut struct {
	TimedOut *durationpb.Duration `protobuf:"bytes,2,opt,name=timed_out,json=timedOut,proto3,oneof"`
}

type UnimplementedInitialSizeClassCacheServer

type UnimplementedInitialSizeClassCacheServer struct {
}

UnimplementedInitialSizeClassCacheServer should be embedded to have forward compatible implementations.

func (UnimplementedInitialSizeClassCacheServer) GetPreviousExecutionStats

func (UnimplementedInitialSizeClassCacheServer) UpdatePreviousExecutionStats

type UnsafeInitialSizeClassCacheServer

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

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

type UpdatePreviousExecutionStatsRequest

type UpdatePreviousExecutionStatsRequest struct {
	InstanceName           string                  `protobuf:"bytes,1,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	ReducedActionDigest    *v2.Digest              `protobuf:"bytes,2,opt,name=reduced_action_digest,json=reducedActionDigest,proto3" json:"reduced_action_digest,omitempty"`
	PreviousExecutionStats *PreviousExecutionStats `` /* 129-byte string literal not displayed */
	DigestFunction         v2.DigestFunction_Value `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdatePreviousExecutionStatsRequest) Descriptor deprecated

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

Deprecated: Use UpdatePreviousExecutionStatsRequest.ProtoReflect.Descriptor instead.

func (*UpdatePreviousExecutionStatsRequest) GetDigestFunction

func (*UpdatePreviousExecutionStatsRequest) GetInstanceName

func (x *UpdatePreviousExecutionStatsRequest) GetInstanceName() string

func (*UpdatePreviousExecutionStatsRequest) GetPreviousExecutionStats

func (x *UpdatePreviousExecutionStatsRequest) GetPreviousExecutionStats() *PreviousExecutionStats

func (*UpdatePreviousExecutionStatsRequest) GetReducedActionDigest

func (x *UpdatePreviousExecutionStatsRequest) GetReducedActionDigest() *v2.Digest

func (*UpdatePreviousExecutionStatsRequest) ProtoMessage

func (*UpdatePreviousExecutionStatsRequest) ProtoMessage()

func (*UpdatePreviousExecutionStatsRequest) ProtoReflect

func (*UpdatePreviousExecutionStatsRequest) Reset

func (*UpdatePreviousExecutionStatsRequest) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL