proto

Documentation

Index

• Variables
• func RegisterRecordUpdateServiceServer(s grpc.ServiceRegistrar, srv RecordUpdateServiceServer)
• type Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (x *Config) GetUpdates() []*Update
  • func (*Config) ProtoMessage()
  • func (x *Config) ProtoReflect() protoreflect.Message
  • func (x *Config) Reset()
  • func (x *Config) String() string
• type RecordUpdateServiceClient
  • func NewRecordUpdateServiceClient(cc grpc.ClientConnInterface) RecordUpdateServiceClient
• type RecordUpdateServiceServer
• type UnimplementedRecordUpdateServiceServer
  • func (UnimplementedRecordUpdateServiceServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
• type UnsafeRecordUpdateServiceServer
• type Update
  • func (*Update) Descriptor() ([]byte, []int)
  • func (x *Update) GetInstanceId() int32
  • func (x *Update) GetNextUpdateTime() int64
  • func (x *Update) GetUpdatePurpose() string
  • func (*Update) ProtoMessage()
  • func (x *Update) ProtoReflect() protoreflect.Message
  • func (x *Update) Reset()
  • func (x *Update) String() string
• type UpdateRequest
  • func (*UpdateRequest) Descriptor() ([]byte, []int)
  • func (x *UpdateRequest) GetInstanceId() int32
  • func (x *UpdateRequest) GetPurpose() string
  • func (x *UpdateRequest) GetUpdateTime() int64
  • func (*UpdateRequest) ProtoMessage()
  • func (x *UpdateRequest) ProtoReflect() protoreflect.Message
  • func (x *UpdateRequest) Reset()
  • func (x *UpdateRequest) String() string
• type UpdateResponse
  • func (*UpdateResponse) Descriptor() ([]byte, []int)
  • func (*UpdateResponse) ProtoMessage()
  • func (x *UpdateResponse) ProtoReflect() protoreflect.Message
  • func (x *UpdateResponse) Reset()
  • func (x *UpdateResponse) String() string

Variables

var File_recordupdater_proto protoreflect.FileDescriptor

var RecordUpdateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "recordupdater.RecordUpdateService",
	HandlerType: (*RecordUpdateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Update",
			Handler:    _RecordUpdateService_Update_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "recordupdater.proto",
}

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

Functions

func RegisterRecordUpdateServiceServer

func RegisterRecordUpdateServiceServer(s grpc.ServiceRegistrar, srv RecordUpdateServiceServer)

Types

type Config

type Config struct {
	Updates []*Update `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates,omitempty"`
	// contains filtered or unexported fields
}

func (*Config) Descriptor

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetUpdates

func (x *Config) GetUpdates() []*Update

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

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

func (*Config) Reset

func (x *Config) Reset()

func (*Config) String

func (x *Config) String() string

type RecordUpdateServiceClient

type RecordUpdateServiceClient interface {
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
}

RecordUpdateServiceClient is the client API for RecordUpdateService 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 NewRecordUpdateServiceClient

func NewRecordUpdateServiceClient(cc grpc.ClientConnInterface) RecordUpdateServiceClient

type RecordUpdateServiceServer

type RecordUpdateServiceServer interface {
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
}

RecordUpdateServiceServer is the server API for RecordUpdateService service. All implementations should embed UnimplementedRecordUpdateServiceServer for forward compatibility

type UnimplementedRecordUpdateServiceServer

type UnimplementedRecordUpdateServiceServer struct {
}

UnimplementedRecordUpdateServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedRecordUpdateServiceServer) Update

func (UnimplementedRecordUpdateServiceServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)

type UnsafeRecordUpdateServiceServer

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

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

type Update

type Update struct {
	InstanceId     int32  `protobuf:"varint,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	NextUpdateTime int64  `protobuf:"varint,2,opt,name=next_update_time,json=nextUpdateTime,proto3" json:"next_update_time,omitempty"`
	UpdatePurpose  string `protobuf:"bytes,3,opt,name=update_purpose,json=updatePurpose,proto3" json:"update_purpose,omitempty"`
	// contains filtered or unexported fields
}

func (*Update) Descriptor

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

Deprecated: Use Update.ProtoReflect.Descriptor instead.

func (*Update) GetInstanceId

func (x *Update) GetInstanceId() int32

func (*Update) GetNextUpdateTime

func (x *Update) GetNextUpdateTime() int64

func (*Update) GetUpdatePurpose

func (x *Update) GetUpdatePurpose() string

func (*Update) ProtoMessage

func (*Update) ProtoMessage()

func (*Update) ProtoReflect

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

func (*Update) Reset

func (x *Update) Reset()

func (*Update) String

func (x *Update) String() string

type UpdateRequest

type UpdateRequest struct {
	InstanceId int32  `protobuf:"varint,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	UpdateTime int64  `protobuf:"varint,2,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	Purpose    string `protobuf:"bytes,3,opt,name=purpose,proto3" json:"purpose,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetInstanceId

func (x *UpdateRequest) GetInstanceId() int32

func (*UpdateRequest) GetPurpose

func (x *UpdateRequest) GetPurpose() string

func (*UpdateRequest) GetUpdateTime

func (x *UpdateRequest) GetUpdateTime() int64

func (*UpdateRequest) ProtoMessage

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect

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

func (*UpdateRequest) Reset

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String

func (x *UpdateRequest) String() string

type UpdateResponse

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

func (*UpdateResponse) Descriptor

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

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) ProtoMessage

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect

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

func (*UpdateResponse) Reset

func (x *UpdateResponse) Reset()

func (*UpdateResponse) String

func (x *UpdateResponse) String() string