Documentation
¶
Index ¶
- Variables
- func RegisterProtoconfCompileServer(s grpc.ServiceRegistrar, srv ProtoconfCompileServer)
- func RegisterProtoconfMutationReportServiceServer(s grpc.ServiceRegistrar, srv ProtoconfMutationReportServiceServer)
- func RegisterProtoconfMutationServiceServer(s grpc.ServiceRegistrar, srv ProtoconfMutationServiceServer)
- func RegisterProtoconfServiceServer(s grpc.ServiceRegistrar, srv ProtoconfServiceServer)
- type CompileRequest
- func (*CompileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompileRequest) GetFiles() []string
- func (x *CompileRequest) GetSkipDisk() bool
- func (*CompileRequest) ProtoMessage()
- func (x *CompileRequest) ProtoReflect() protoreflect.Message
- func (x *CompileRequest) Reset()
- func (x *CompileRequest) String() string
- type CompileResponse
- func (*CompileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CompileResponse) GetErrors() []string
- func (x *CompileResponse) GetFile() string
- func (x *CompileResponse) GetPath() string
- func (x *CompileResponse) GetResult() *ProtoconfValue
- func (*CompileResponse) ProtoMessage()
- func (x *CompileResponse) ProtoReflect() protoreflect.Message
- func (x *CompileResponse) Reset()
- func (x *CompileResponse) String() string
- type ConfigMutationRequest
- func (*ConfigMutationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigMutationRequest) GetPath() string
- func (x *ConfigMutationRequest) GetScriptMetadata() string
- func (x *ConfigMutationRequest) GetValue() *ProtoconfValue
- func (*ConfigMutationRequest) ProtoMessage()
- func (x *ConfigMutationRequest) ProtoReflect() protoreflect.Message
- func (x *ConfigMutationRequest) Reset()
- func (x *ConfigMutationRequest) String() string
- type ConfigMutationResponse
- func (*ConfigMutationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigMutationResponse) GetCommitHash() string
- func (x *ConfigMutationResponse) GetCompileDuration() *durationpb.Duration
- func (x *ConfigMutationResponse) GetErrorMessage() string
- func (x *ConfigMutationResponse) GetFailure() bool
- func (x *ConfigMutationResponse) GetLinks() map[string]string
- func (x *ConfigMutationResponse) GetPostScriptDuration() *durationpb.Duration
- func (x *ConfigMutationResponse) GetPreScriptDuration() *durationpb.Duration
- func (m *ConfigMutationResponse) GetResult() isConfigMutationResponse_Result
- func (x *ConfigMutationResponse) GetSuccess() bool
- func (x *ConfigMutationResponse) GetUuid() string
- func (*ConfigMutationResponse) ProtoMessage()
- func (x *ConfigMutationResponse) ProtoReflect() protoreflect.Message
- func (x *ConfigMutationResponse) Reset()
- func (x *ConfigMutationResponse) String() string
- type ConfigMutationResponse_Failure
- type ConfigMutationResponse_Success
- type ConfigSubscriptionRequest
- func (*ConfigSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigSubscriptionRequest) GetChannel() string
- func (x *ConfigSubscriptionRequest) GetPath() string
- func (*ConfigSubscriptionRequest) ProtoMessage()
- func (x *ConfigSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *ConfigSubscriptionRequest) Reset()
- func (x *ConfigSubscriptionRequest) String() string
- type ConfigUpdate
- func (*ConfigUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigUpdate) GetError() string
- func (x *ConfigUpdate) GetValue() *anypb.Any
- func (*ConfigUpdate) ProtoMessage()
- func (x *ConfigUpdate) ProtoReflect() protoreflect.Message
- func (x *ConfigUpdate) Reset()
- func (x *ConfigUpdate) String() string
- type Metadata
- func (*Metadata) Descriptor() ([]byte, []int)deprecated
- func (x *Metadata) GetAuthorEmail() string
- func (x *Metadata) GetAuthoredAt() *timestamppb.Timestamp
- func (x *Metadata) GetChannel() string
- func (x *Metadata) GetCommit() string
- func (x *Metadata) GetCommittedAt() *timestamppb.Timestamp
- func (x *Metadata) GetCommitterEmail() string
- func (x *Metadata) GetInsertedAt() *timestamppb.Timestamp
- func (*Metadata) ProtoMessage()
- func (x *Metadata) ProtoReflect() protoreflect.Message
- func (x *Metadata) Reset()
- func (x *Metadata) String() string
- type ProtoconfCompileClient
- type ProtoconfCompileServer
- type ProtoconfCompile_CompileFilesClient
- type ProtoconfCompile_CompileFilesServer
- type ProtoconfMutationReportServiceClient
- type ProtoconfMutationReportServiceServer
- type ProtoconfMutationServiceClient
- type ProtoconfMutationServiceServer
- type ProtoconfServiceClient
- type ProtoconfServiceServer
- type ProtoconfService_SubscribeForConfigClient
- type ProtoconfService_SubscribeForConfigServer
- type ProtoconfValue
- func (*ProtoconfValue) Descriptor() ([]byte, []int)deprecated
- func (x *ProtoconfValue) GetMetadata() *Metadata
- func (x *ProtoconfValue) GetProtoFile() string
- func (x *ProtoconfValue) GetRolloutConfig() *ProtoconfValue_ConfigRollout
- func (x *ProtoconfValue) GetValue() *anypb.Any
- func (*ProtoconfValue) ProtoMessage()
- func (x *ProtoconfValue) ProtoReflect() protoreflect.Message
- func (x *ProtoconfValue) Reset()
- func (x *ProtoconfValue) String() string
- type ProtoconfValue_ConfigRollout
- func (*ProtoconfValue_ConfigRollout) Descriptor() ([]byte, []int)deprecated
- func (x *ProtoconfValue_ConfigRollout) GetDefaultCooldownTime() *durationpb.Duration
- func (x *ProtoconfValue_ConfigRollout) GetDefaultExpirationTime() *durationpb.Duration
- func (x *ProtoconfValue_ConfigRollout) GetNamespace() string
- func (x *ProtoconfValue_ConfigRollout) GetStages() []*ProtoconfValue_ConfigRollout_Stage
- func (*ProtoconfValue_ConfigRollout) ProtoMessage()
- func (x *ProtoconfValue_ConfigRollout) ProtoReflect() protoreflect.Message
- func (x *ProtoconfValue_ConfigRollout) Reset()
- func (x *ProtoconfValue_ConfigRollout) String() string
- type ProtoconfValue_ConfigRollout_Stage
- func (*ProtoconfValue_ConfigRollout_Stage) Descriptor() ([]byte, []int)deprecated
- func (x *ProtoconfValue_ConfigRollout_Stage) GetChannel() string
- func (x *ProtoconfValue_ConfigRollout_Stage) GetCooldown() *durationpb.Duration
- func (x *ProtoconfValue_ConfigRollout_Stage) GetExpiration() *durationpb.Duration
- func (x *ProtoconfValue_ConfigRollout_Stage) GetExpiresAt() *timestamppb.Timestamp
- func (x *ProtoconfValue_ConfigRollout_Stage) GetLabels() map[string]string
- func (x *ProtoconfValue_ConfigRollout_Stage) GetManual() bool
- func (x *ProtoconfValue_ConfigRollout_Stage) GetPercentile() uint32
- func (x *ProtoconfValue_ConfigRollout_Stage) GetVersion() string
- func (*ProtoconfValue_ConfigRollout_Stage) ProtoMessage()
- func (x *ProtoconfValue_ConfigRollout_Stage) ProtoReflect() protoreflect.Message
- func (x *ProtoconfValue_ConfigRollout_Stage) Reset()
- func (x *ProtoconfValue_ConfigRollout_Stage) String() string
- type UnimplementedProtoconfCompileServer
- type UnimplementedProtoconfMutationReportServiceServer
- type UnimplementedProtoconfMutationServiceServer
- type UnimplementedProtoconfServiceServer
- type UnsafeProtoconfCompileServer
- type UnsafeProtoconfMutationReportServiceServer
- type UnsafeProtoconfMutationServiceServer
- type UnsafeProtoconfServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_protoconf_v1_protoconf_proto protoreflect.FileDescriptor
var ProtoconfCompile_ServiceDesc = grpc.ServiceDesc{ ServiceName: "protoconf.v1.ProtoconfCompile", HandlerType: (*ProtoconfCompileServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "CompileFiles", Handler: _ProtoconfCompile_CompileFiles_Handler, ServerStreams: true, }, }, Metadata: "protoconf/v1/protoconf.proto", }
ProtoconfCompile_ServiceDesc is the grpc.ServiceDesc for ProtoconfCompile service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ProtoconfMutationReportService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "protoconf.v1.ProtoconfMutationReportService", HandlerType: (*ProtoconfMutationReportServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ReportProgress", Handler: _ProtoconfMutationReportService_ReportProgress_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "protoconf/v1/protoconf.proto", }
ProtoconfMutationReportService_ServiceDesc is the grpc.ServiceDesc for ProtoconfMutationReportService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ProtoconfMutationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "protoconf.v1.ProtoconfMutationService", HandlerType: (*ProtoconfMutationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "MutateConfig", Handler: _ProtoconfMutationService_MutateConfig_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "protoconf/v1/protoconf.proto", }
ProtoconfMutationService_ServiceDesc is the grpc.ServiceDesc for ProtoconfMutationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ProtoconfService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "protoconf.v1.ProtoconfService", HandlerType: (*ProtoconfServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "SubscribeForConfig", Handler: _ProtoconfService_SubscribeForConfig_Handler, ServerStreams: true, }, }, Metadata: "protoconf/v1/protoconf.proto", }
ProtoconfService_ServiceDesc is the grpc.ServiceDesc for ProtoconfService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterProtoconfCompileServer ¶
func RegisterProtoconfCompileServer(s grpc.ServiceRegistrar, srv ProtoconfCompileServer)
func RegisterProtoconfMutationReportServiceServer ¶
func RegisterProtoconfMutationReportServiceServer(s grpc.ServiceRegistrar, srv ProtoconfMutationReportServiceServer)
func RegisterProtoconfMutationServiceServer ¶
func RegisterProtoconfMutationServiceServer(s grpc.ServiceRegistrar, srv ProtoconfMutationServiceServer)
func RegisterProtoconfServiceServer ¶
func RegisterProtoconfServiceServer(s grpc.ServiceRegistrar, srv ProtoconfServiceServer)
Types ¶
type CompileRequest ¶
type CompileRequest struct { Files []string `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"` SkipDisk bool `protobuf:"varint,2,opt,name=skip_disk,json=skipDisk,proto3" json:"skip_disk,omitempty"` // contains filtered or unexported fields }
Compiler
func (*CompileRequest) Descriptor
deprecated
func (*CompileRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompileRequest.ProtoReflect.Descriptor instead.
func (*CompileRequest) GetFiles ¶
func (x *CompileRequest) GetFiles() []string
func (*CompileRequest) GetSkipDisk ¶
func (x *CompileRequest) GetSkipDisk() bool
func (*CompileRequest) ProtoMessage ¶
func (*CompileRequest) ProtoMessage()
func (*CompileRequest) ProtoReflect ¶
func (x *CompileRequest) ProtoReflect() protoreflect.Message
func (*CompileRequest) Reset ¶
func (x *CompileRequest) Reset()
func (*CompileRequest) String ¶
func (x *CompileRequest) String() string
type CompileResponse ¶
type CompileResponse struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Result *ProtoconfValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` File string `protobuf:"bytes,3,opt,name=file,proto3" json:"file,omitempty"` Errors []string `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"` // contains filtered or unexported fields }
func (*CompileResponse) Descriptor
deprecated
func (*CompileResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompileResponse.ProtoReflect.Descriptor instead.
func (*CompileResponse) GetErrors ¶
func (x *CompileResponse) GetErrors() []string
func (*CompileResponse) GetFile ¶
func (x *CompileResponse) GetFile() string
func (*CompileResponse) GetPath ¶
func (x *CompileResponse) GetPath() string
func (*CompileResponse) GetResult ¶
func (x *CompileResponse) GetResult() *ProtoconfValue
func (*CompileResponse) ProtoMessage ¶
func (*CompileResponse) ProtoMessage()
func (*CompileResponse) ProtoReflect ¶
func (x *CompileResponse) ProtoReflect() protoreflect.Message
func (*CompileResponse) Reset ¶
func (x *CompileResponse) Reset()
func (*CompileResponse) String ¶
func (x *CompileResponse) String() string
type ConfigMutationRequest ¶
type ConfigMutationRequest struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Value *ProtoconfValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` ScriptMetadata string `protobuf:"bytes,3,opt,name=script_metadata,json=scriptMetadata,proto3" json:"script_metadata,omitempty"` // contains filtered or unexported fields }
Mutation Server
func (*ConfigMutationRequest) Descriptor
deprecated
func (*ConfigMutationRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigMutationRequest.ProtoReflect.Descriptor instead.
func (*ConfigMutationRequest) GetPath ¶
func (x *ConfigMutationRequest) GetPath() string
func (*ConfigMutationRequest) GetScriptMetadata ¶
func (x *ConfigMutationRequest) GetScriptMetadata() string
func (*ConfigMutationRequest) GetValue ¶
func (x *ConfigMutationRequest) GetValue() *ProtoconfValue
func (*ConfigMutationRequest) ProtoMessage ¶
func (*ConfigMutationRequest) ProtoMessage()
func (*ConfigMutationRequest) ProtoReflect ¶
func (x *ConfigMutationRequest) ProtoReflect() protoreflect.Message
func (*ConfigMutationRequest) Reset ¶
func (x *ConfigMutationRequest) Reset()
func (*ConfigMutationRequest) String ¶
func (x *ConfigMutationRequest) String() string
type ConfigMutationResponse ¶
type ConfigMutationResponse struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` CommitHash string `protobuf:"bytes,2,opt,name=commit_hash,json=commitHash,proto3" json:"commit_hash,omitempty"` Links map[string]string `` /* 151-byte string literal not displayed */ // Types that are assignable to Result: // *ConfigMutationResponse_Success // *ConfigMutationResponse_Failure Result isConfigMutationResponse_Result `protobuf_oneof:"result"` ErrorMessage string `protobuf:"bytes,6,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` PreScriptDuration *durationpb.Duration `protobuf:"bytes,7,opt,name=pre_script_duration,json=preScriptDuration,proto3" json:"pre_script_duration,omitempty"` PostScriptDuration *durationpb.Duration `protobuf:"bytes,8,opt,name=post_script_duration,json=postScriptDuration,proto3" json:"post_script_duration,omitempty"` CompileDuration *durationpb.Duration `protobuf:"bytes,9,opt,name=compile_duration,json=compileDuration,proto3" json:"compile_duration,omitempty"` // contains filtered or unexported fields }
func (*ConfigMutationResponse) Descriptor
deprecated
func (*ConfigMutationResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigMutationResponse.ProtoReflect.Descriptor instead.
func (*ConfigMutationResponse) GetCommitHash ¶
func (x *ConfigMutationResponse) GetCommitHash() string
func (*ConfigMutationResponse) GetCompileDuration ¶
func (x *ConfigMutationResponse) GetCompileDuration() *durationpb.Duration
func (*ConfigMutationResponse) GetErrorMessage ¶
func (x *ConfigMutationResponse) GetErrorMessage() string
func (*ConfigMutationResponse) GetFailure ¶
func (x *ConfigMutationResponse) GetFailure() bool
func (*ConfigMutationResponse) GetLinks ¶
func (x *ConfigMutationResponse) GetLinks() map[string]string
func (*ConfigMutationResponse) GetPostScriptDuration ¶
func (x *ConfigMutationResponse) GetPostScriptDuration() *durationpb.Duration
func (*ConfigMutationResponse) GetPreScriptDuration ¶
func (x *ConfigMutationResponse) GetPreScriptDuration() *durationpb.Duration
func (*ConfigMutationResponse) GetResult ¶
func (m *ConfigMutationResponse) GetResult() isConfigMutationResponse_Result
func (*ConfigMutationResponse) GetSuccess ¶
func (x *ConfigMutationResponse) GetSuccess() bool
func (*ConfigMutationResponse) GetUuid ¶
func (x *ConfigMutationResponse) GetUuid() string
func (*ConfigMutationResponse) ProtoMessage ¶
func (*ConfigMutationResponse) ProtoMessage()
func (*ConfigMutationResponse) ProtoReflect ¶
func (x *ConfigMutationResponse) ProtoReflect() protoreflect.Message
func (*ConfigMutationResponse) Reset ¶
func (x *ConfigMutationResponse) Reset()
func (*ConfigMutationResponse) String ¶
func (x *ConfigMutationResponse) String() string
type ConfigMutationResponse_Failure ¶
type ConfigMutationResponse_Failure struct {
Failure bool `protobuf:"varint,5,opt,name=failure,proto3,oneof"`
}
type ConfigMutationResponse_Success ¶
type ConfigMutationResponse_Success struct {
Success bool `protobuf:"varint,4,opt,name=success,proto3,oneof"`
}
type ConfigSubscriptionRequest ¶
type ConfigSubscriptionRequest struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"` // contains filtered or unexported fields }
func (*ConfigSubscriptionRequest) Descriptor
deprecated
func (*ConfigSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*ConfigSubscriptionRequest) GetChannel ¶
func (x *ConfigSubscriptionRequest) GetChannel() string
func (*ConfigSubscriptionRequest) GetPath ¶
func (x *ConfigSubscriptionRequest) GetPath() string
func (*ConfigSubscriptionRequest) ProtoMessage ¶
func (*ConfigSubscriptionRequest) ProtoMessage()
func (*ConfigSubscriptionRequest) ProtoReflect ¶
func (x *ConfigSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*ConfigSubscriptionRequest) Reset ¶
func (x *ConfigSubscriptionRequest) Reset()
func (*ConfigSubscriptionRequest) String ¶
func (x *ConfigSubscriptionRequest) String() string
type ConfigUpdate ¶
type ConfigUpdate struct { Value *anypb.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*ConfigUpdate) Descriptor
deprecated
func (*ConfigUpdate) Descriptor() ([]byte, []int)
Deprecated: Use ConfigUpdate.ProtoReflect.Descriptor instead.
func (*ConfigUpdate) GetError ¶
func (x *ConfigUpdate) GetError() string
func (*ConfigUpdate) GetValue ¶
func (x *ConfigUpdate) GetValue() *anypb.Any
func (*ConfigUpdate) ProtoMessage ¶
func (*ConfigUpdate) ProtoMessage()
func (*ConfigUpdate) ProtoReflect ¶
func (x *ConfigUpdate) ProtoReflect() protoreflect.Message
func (*ConfigUpdate) Reset ¶
func (x *ConfigUpdate) Reset()
func (*ConfigUpdate) String ¶
func (x *ConfigUpdate) String() string
type Metadata ¶
type Metadata struct { Commit string `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"` CommitterEmail string `protobuf:"bytes,2,opt,name=committer_email,json=committerEmail,proto3" json:"committer_email,omitempty"` AuthorEmail string `protobuf:"bytes,3,opt,name=author_email,json=authorEmail,proto3" json:"author_email,omitempty"` CommittedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=committed_at,json=committedAt,proto3" json:"committed_at,omitempty"` AuthoredAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=authored_at,json=authoredAt,proto3" json:"authored_at,omitempty"` InsertedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=inserted_at,json=insertedAt,proto3" json:"inserted_at,omitempty"` Channel string `protobuf:"bytes,7,opt,name=channel,proto3" json:"channel,omitempty"` // contains filtered or unexported fields }
Agent
func (*Metadata) Descriptor
deprecated
func (*Metadata) GetAuthorEmail ¶
func (*Metadata) GetAuthoredAt ¶
func (x *Metadata) GetAuthoredAt() *timestamppb.Timestamp
func (*Metadata) GetChannel ¶
func (*Metadata) GetCommittedAt ¶
func (x *Metadata) GetCommittedAt() *timestamppb.Timestamp
func (*Metadata) GetCommitterEmail ¶
func (*Metadata) GetInsertedAt ¶
func (x *Metadata) GetInsertedAt() *timestamppb.Timestamp
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) ProtoReflect ¶
func (x *Metadata) ProtoReflect() protoreflect.Message
type ProtoconfCompileClient ¶
type ProtoconfCompileClient interface {
CompileFiles(ctx context.Context, in *CompileRequest, opts ...grpc.CallOption) (ProtoconfCompile_CompileFilesClient, error)
}
ProtoconfCompileClient is the client API for ProtoconfCompile 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 NewProtoconfCompileClient ¶
func NewProtoconfCompileClient(cc grpc.ClientConnInterface) ProtoconfCompileClient
type ProtoconfCompileServer ¶
type ProtoconfCompileServer interface { CompileFiles(*CompileRequest, ProtoconfCompile_CompileFilesServer) error // contains filtered or unexported methods }
ProtoconfCompileServer is the server API for ProtoconfCompile service. All implementations must embed UnimplementedProtoconfCompileServer for forward compatibility
type ProtoconfCompile_CompileFilesClient ¶
type ProtoconfCompile_CompileFilesClient interface { Recv() (*CompileResponse, error) grpc.ClientStream }
type ProtoconfCompile_CompileFilesServer ¶
type ProtoconfCompile_CompileFilesServer interface { Send(*CompileResponse) error grpc.ServerStream }
type ProtoconfMutationReportServiceClient ¶
type ProtoconfMutationReportServiceClient interface {
ReportProgress(ctx context.Context, in *ConfigMutationResponse, opts ...grpc.CallOption) (*ConfigMutationResponse, error)
}
ProtoconfMutationReportServiceClient is the client API for ProtoconfMutationReportService 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 NewProtoconfMutationReportServiceClient ¶
func NewProtoconfMutationReportServiceClient(cc grpc.ClientConnInterface) ProtoconfMutationReportServiceClient
type ProtoconfMutationReportServiceServer ¶
type ProtoconfMutationReportServiceServer interface { ReportProgress(context.Context, *ConfigMutationResponse) (*ConfigMutationResponse, error) // contains filtered or unexported methods }
ProtoconfMutationReportServiceServer is the server API for ProtoconfMutationReportService service. All implementations must embed UnimplementedProtoconfMutationReportServiceServer for forward compatibility
type ProtoconfMutationServiceClient ¶
type ProtoconfMutationServiceClient interface {
MutateConfig(ctx context.Context, in *ConfigMutationRequest, opts ...grpc.CallOption) (*ConfigMutationResponse, error)
}
ProtoconfMutationServiceClient is the client API for ProtoconfMutationService 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 NewProtoconfMutationServiceClient ¶
func NewProtoconfMutationServiceClient(cc grpc.ClientConnInterface) ProtoconfMutationServiceClient
type ProtoconfMutationServiceServer ¶
type ProtoconfMutationServiceServer interface { MutateConfig(context.Context, *ConfigMutationRequest) (*ConfigMutationResponse, error) // contains filtered or unexported methods }
ProtoconfMutationServiceServer is the server API for ProtoconfMutationService service. All implementations must embed UnimplementedProtoconfMutationServiceServer for forward compatibility
type ProtoconfServiceClient ¶
type ProtoconfServiceClient interface {
SubscribeForConfig(ctx context.Context, in *ConfigSubscriptionRequest, opts ...grpc.CallOption) (ProtoconfService_SubscribeForConfigClient, error)
}
ProtoconfServiceClient is the client API for ProtoconfService 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 NewProtoconfServiceClient ¶
func NewProtoconfServiceClient(cc grpc.ClientConnInterface) ProtoconfServiceClient
type ProtoconfServiceServer ¶
type ProtoconfServiceServer interface { SubscribeForConfig(*ConfigSubscriptionRequest, ProtoconfService_SubscribeForConfigServer) error // contains filtered or unexported methods }
ProtoconfServiceServer is the server API for ProtoconfService service. All implementations must embed UnimplementedProtoconfServiceServer for forward compatibility
type ProtoconfService_SubscribeForConfigClient ¶
type ProtoconfService_SubscribeForConfigClient interface { Recv() (*ConfigUpdate, error) grpc.ClientStream }
type ProtoconfService_SubscribeForConfigServer ¶
type ProtoconfService_SubscribeForConfigServer interface { Send(*ConfigUpdate) error grpc.ServerStream }
type ProtoconfValue ¶
type ProtoconfValue struct { ProtoFile string `protobuf:"bytes,1,opt,name=proto_file,json=protoFile,proto3" json:"proto_file,omitempty"` Value *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` RolloutConfig *ProtoconfValue_ConfigRollout `protobuf:"bytes,3,opt,name=rollout_config,json=rolloutConfig,proto3" json:"rollout_config,omitempty"` Metadata *Metadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*ProtoconfValue) Descriptor
deprecated
func (*ProtoconfValue) Descriptor() ([]byte, []int)
Deprecated: Use ProtoconfValue.ProtoReflect.Descriptor instead.
func (*ProtoconfValue) GetMetadata ¶
func (x *ProtoconfValue) GetMetadata() *Metadata
func (*ProtoconfValue) GetProtoFile ¶
func (x *ProtoconfValue) GetProtoFile() string
func (*ProtoconfValue) GetRolloutConfig ¶
func (x *ProtoconfValue) GetRolloutConfig() *ProtoconfValue_ConfigRollout
func (*ProtoconfValue) GetValue ¶
func (x *ProtoconfValue) GetValue() *anypb.Any
func (*ProtoconfValue) ProtoMessage ¶
func (*ProtoconfValue) ProtoMessage()
func (*ProtoconfValue) ProtoReflect ¶
func (x *ProtoconfValue) ProtoReflect() protoreflect.Message
func (*ProtoconfValue) Reset ¶
func (x *ProtoconfValue) Reset()
func (*ProtoconfValue) String ¶
func (x *ProtoconfValue) String() string
type ProtoconfValue_ConfigRollout ¶
type ProtoconfValue_ConfigRollout struct { // cooldown is the duration of time the inserter waits before applying // the next stage, Uses protobuf google.protobuf.Duration well-known-type DefaultCooldownTime *durationpb.Duration `protobuf:"bytes,1,opt,name=default_cooldown_time,json=defaultCooldownTime,proto3" json:"default_cooldown_time,omitempty"` // expiration will be added to the time of insertion to be set as // `expires_at`. When `expires_at` is due, the config should revert // to default. DefaultExpirationTime *durationpb.Duration `` /* 126-byte string literal not displayed */ Stages []*ProtoconfValue_ConfigRollout_Stage `protobuf:"bytes,3,rep,name=stages,proto3" json:"stages,omitempty"` Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*ProtoconfValue_ConfigRollout) Descriptor
deprecated
func (*ProtoconfValue_ConfigRollout) Descriptor() ([]byte, []int)
Deprecated: Use ProtoconfValue_ConfigRollout.ProtoReflect.Descriptor instead.
func (*ProtoconfValue_ConfigRollout) GetDefaultCooldownTime ¶
func (x *ProtoconfValue_ConfigRollout) GetDefaultCooldownTime() *durationpb.Duration
func (*ProtoconfValue_ConfigRollout) GetDefaultExpirationTime ¶
func (x *ProtoconfValue_ConfigRollout) GetDefaultExpirationTime() *durationpb.Duration
func (*ProtoconfValue_ConfigRollout) GetNamespace ¶
func (x *ProtoconfValue_ConfigRollout) GetNamespace() string
func (*ProtoconfValue_ConfigRollout) GetStages ¶
func (x *ProtoconfValue_ConfigRollout) GetStages() []*ProtoconfValue_ConfigRollout_Stage
func (*ProtoconfValue_ConfigRollout) ProtoMessage ¶
func (*ProtoconfValue_ConfigRollout) ProtoMessage()
func (*ProtoconfValue_ConfigRollout) ProtoReflect ¶
func (x *ProtoconfValue_ConfigRollout) ProtoReflect() protoreflect.Message
func (*ProtoconfValue_ConfigRollout) Reset ¶
func (x *ProtoconfValue_ConfigRollout) Reset()
func (*ProtoconfValue_ConfigRollout) String ¶
func (x *ProtoconfValue_ConfigRollout) String() string
type ProtoconfValue_ConfigRollout_Stage ¶
type ProtoconfValue_ConfigRollout_Stage struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` Percentile uint32 `protobuf:"varint,2,opt,name=percentile,proto3" json:"percentile,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ Manual bool `protobuf:"varint,4,opt,name=manual,proto3" json:"manual,omitempty"` Cooldown *durationpb.Duration `protobuf:"bytes,5,opt,name=cooldown,proto3" json:"cooldown,omitempty"` Expiration *durationpb.Duration `protobuf:"bytes,6,opt,name=expiration,proto3" json:"expiration,omitempty"` ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"` Version string `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*ProtoconfValue_ConfigRollout_Stage) Descriptor
deprecated
func (*ProtoconfValue_ConfigRollout_Stage) Descriptor() ([]byte, []int)
Deprecated: Use ProtoconfValue_ConfigRollout_Stage.ProtoReflect.Descriptor instead.
func (*ProtoconfValue_ConfigRollout_Stage) GetChannel ¶
func (x *ProtoconfValue_ConfigRollout_Stage) GetChannel() string
func (*ProtoconfValue_ConfigRollout_Stage) GetCooldown ¶
func (x *ProtoconfValue_ConfigRollout_Stage) GetCooldown() *durationpb.Duration
func (*ProtoconfValue_ConfigRollout_Stage) GetExpiration ¶
func (x *ProtoconfValue_ConfigRollout_Stage) GetExpiration() *durationpb.Duration
func (*ProtoconfValue_ConfigRollout_Stage) GetExpiresAt ¶
func (x *ProtoconfValue_ConfigRollout_Stage) GetExpiresAt() *timestamppb.Timestamp
func (*ProtoconfValue_ConfigRollout_Stage) GetLabels ¶
func (x *ProtoconfValue_ConfigRollout_Stage) GetLabels() map[string]string
func (*ProtoconfValue_ConfigRollout_Stage) GetManual ¶
func (x *ProtoconfValue_ConfigRollout_Stage) GetManual() bool
func (*ProtoconfValue_ConfigRollout_Stage) GetPercentile ¶
func (x *ProtoconfValue_ConfigRollout_Stage) GetPercentile() uint32
func (*ProtoconfValue_ConfigRollout_Stage) GetVersion ¶
func (x *ProtoconfValue_ConfigRollout_Stage) GetVersion() string
func (*ProtoconfValue_ConfigRollout_Stage) ProtoMessage ¶
func (*ProtoconfValue_ConfigRollout_Stage) ProtoMessage()
func (*ProtoconfValue_ConfigRollout_Stage) ProtoReflect ¶
func (x *ProtoconfValue_ConfigRollout_Stage) ProtoReflect() protoreflect.Message
func (*ProtoconfValue_ConfigRollout_Stage) Reset ¶
func (x *ProtoconfValue_ConfigRollout_Stage) Reset()
func (*ProtoconfValue_ConfigRollout_Stage) String ¶
func (x *ProtoconfValue_ConfigRollout_Stage) String() string
type UnimplementedProtoconfCompileServer ¶
type UnimplementedProtoconfCompileServer struct { }
UnimplementedProtoconfCompileServer must be embedded to have forward compatible implementations.
func (UnimplementedProtoconfCompileServer) CompileFiles ¶
func (UnimplementedProtoconfCompileServer) CompileFiles(*CompileRequest, ProtoconfCompile_CompileFilesServer) error
type UnimplementedProtoconfMutationReportServiceServer ¶
type UnimplementedProtoconfMutationReportServiceServer struct { }
UnimplementedProtoconfMutationReportServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedProtoconfMutationReportServiceServer) ReportProgress ¶
func (UnimplementedProtoconfMutationReportServiceServer) ReportProgress(context.Context, *ConfigMutationResponse) (*ConfigMutationResponse, error)
type UnimplementedProtoconfMutationServiceServer ¶
type UnimplementedProtoconfMutationServiceServer struct { }
UnimplementedProtoconfMutationServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedProtoconfMutationServiceServer) MutateConfig ¶
func (UnimplementedProtoconfMutationServiceServer) MutateConfig(context.Context, *ConfigMutationRequest) (*ConfigMutationResponse, error)
type UnimplementedProtoconfServiceServer ¶
type UnimplementedProtoconfServiceServer struct { }
UnimplementedProtoconfServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedProtoconfServiceServer) SubscribeForConfig ¶
func (UnimplementedProtoconfServiceServer) SubscribeForConfig(*ConfigSubscriptionRequest, ProtoconfService_SubscribeForConfigServer) error
type UnsafeProtoconfCompileServer ¶
type UnsafeProtoconfCompileServer interface {
// contains filtered or unexported methods
}
UnsafeProtoconfCompileServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProtoconfCompileServer will result in compilation errors.
type UnsafeProtoconfMutationReportServiceServer ¶
type UnsafeProtoconfMutationReportServiceServer interface {
// contains filtered or unexported methods
}
UnsafeProtoconfMutationReportServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProtoconfMutationReportServiceServer will result in compilation errors.
type UnsafeProtoconfMutationServiceServer ¶
type UnsafeProtoconfMutationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeProtoconfMutationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProtoconfMutationServiceServer will result in compilation errors.
type UnsafeProtoconfServiceServer ¶
type UnsafeProtoconfServiceServer interface {
// contains filtered or unexported methods
}
UnsafeProtoconfServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProtoconfServiceServer will result in compilation errors.