iscc

package
v0.0.0-...-ff8c80c Latest Latest
Warning

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

 Go to latest Published: Dec 20, 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 (x *GetPreviousExecutionStatsRequest) GetDigestFunction() v2.DigestFunction_Value

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 (x *GetPreviousExecutionStatsRequest) ProtoReflect() protoreflect.Message

func (*GetPreviousExecutionStatsRequest) Reset 

func (x *GetPreviousExecutionStatsRequest) Reset()

func (*GetPreviousExecutionStatsRequest) String 

func (x *GetPreviousExecutionStatsRequest) String() 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.

func NewInitialSizeClassCacheClient 

func NewInitialSizeClassCacheClient(cc grpc.ClientConnInterface) InitialSizeClassCacheClient

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) GetPreviousExecutionStats(context.Context, *GetPreviousExecutionStatsRequest) (*PreviousExecutionStats, error)

func (UnimplementedInitialSizeClassCacheServer) UpdatePreviousExecutionStats 

func (UnimplementedInitialSizeClassCacheServer) UpdatePreviousExecutionStats(context.Context, *UpdatePreviousExecutionStatsRequest) (*emptypb.Empty, error)

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 (x *UpdatePreviousExecutionStatsRequest) GetDigestFunction() v2.DigestFunction_Value

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 (x *UpdatePreviousExecutionStatsRequest) ProtoReflect() protoreflect.Message

func (*UpdatePreviousExecutionStatsRequest) Reset 

func (x *UpdatePreviousExecutionStatsRequest) Reset()

func (*UpdatePreviousExecutionStatsRequest) String 

func (x *UpdatePreviousExecutionStatsRequest) String() string

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.