recordmover

package
v0.0.0-...-c60d4c8 Latest Latest
Warning

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

 Go to latest Published: Dec 30, 2024 License: Apache-2.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_recordmover_proto protoreflect.FileDescriptor

Functions

func RegisterMoveServiceServer 

func RegisterMoveServiceServer(s *grpc.Server, srv MoveServiceServer)

Types

type ClearRequest 

type ClearRequest struct {
	InstanceId int32 `protobuf:"varint,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ClearRequest) Descriptor deprecated 

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

Deprecated: Use ClearRequest.ProtoReflect.Descriptor instead.

func (*ClearRequest) GetInstanceId 

func (x *ClearRequest) GetInstanceId() int32

func (*ClearRequest) ProtoMessage 

func (*ClearRequest) ProtoMessage()

func (*ClearRequest) ProtoReflect 

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

func (*ClearRequest) Reset 

func (x *ClearRequest) Reset()

func (*ClearRequest) String 

func (x *ClearRequest) String() string

type ClearResponse 

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

func (*ClearResponse) Descriptor deprecated 

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

Deprecated: Use ClearResponse.ProtoReflect.Descriptor instead.

func (*ClearResponse) ProtoMessage 

func (*ClearResponse) ProtoMessage()

func (*ClearResponse) ProtoReflect 

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

func (*ClearResponse) Reset 

func (x *ClearResponse) Reset()

func (*ClearResponse) String 

func (x *ClearResponse) String() string

type Config 

type Config struct {
	Moves          []*RecordMove   `protobuf:"bytes,1,rep,name=moves,proto3" json:"moves,omitempty"`
	MoveArchive    []*RecordedMove `protobuf:"bytes,2,rep,name=move_archive,json=moveArchive,proto3" json:"move_archive,omitempty"`
	LastPull       int64           `protobuf:"varint,3,opt,name=last_pull,json=lastPull,proto3" json:"last_pull,omitempty"`
	NextUpdateTime map[int32]int64 `` /* 195-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetLastPull 

func (x *Config) GetLastPull() int64

func (*Config) GetMoveArchive 

func (x *Config) GetMoveArchive() []*RecordedMove

func (*Config) GetMoves 

func (x *Config) GetMoves() []*RecordMove

func (*Config) GetNextUpdateTime 

func (x *Config) GetNextUpdateTime() map[int32]int64

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 Context 

type Context struct {
	Before         *proto1.Record `protobuf:"bytes,1,opt,name=before,proto3" json:"before,omitempty"` // DEPRECATED
	BeforeInstance int32          `protobuf:"varint,5,opt,name=before_instance,json=beforeInstance,proto3" json:"before_instance,omitempty"`
	Location       string         `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
	After          *proto1.Record `protobuf:"bytes,3,opt,name=after,proto3" json:"after,omitempty"` // DEPRECATED
	AfterInstance  int32          `protobuf:"varint,6,opt,name=after_instance,json=afterInstance,proto3" json:"after_instance,omitempty"`
	Slot           int32          `protobuf:"varint,4,opt,name=slot,proto3" json:"slot,omitempty"`
	// contains filtered or unexported fields
}

func (*Context) Descriptor deprecated 

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

Deprecated: Use Context.ProtoReflect.Descriptor instead.

func (*Context) GetAfter 

func (x *Context) GetAfter() *proto1.Record

func (*Context) GetAfterInstance 

func (x *Context) GetAfterInstance() int32

func (*Context) GetBefore 

func (x *Context) GetBefore() *proto1.Record

func (*Context) GetBeforeInstance 

func (x *Context) GetBeforeInstance() int32

func (*Context) GetLocation 

func (x *Context) GetLocation() string

func (*Context) GetSlot 

func (x *Context) GetSlot() int32

func (*Context) ProtoMessage 

func (*Context) ProtoMessage()

func (*Context) ProtoReflect 

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

func (*Context) Reset 

func (x *Context) Reset()

func (*Context) String 

func (x *Context) String() string

type ListRequest 

type ListRequest struct {
	InstanceId int32 `protobuf:"varint,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetInstanceId 

func (x *ListRequest) GetInstanceId() int32

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Moves    []*RecordMove   `protobuf:"bytes,1,rep,name=moves,proto3" json:"moves,omitempty"`
	Archives []*RecordedMove `protobuf:"bytes,2,rep,name=archives,proto3" json:"archives,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetArchives 

func (x *ListResponse) GetArchives() []*RecordedMove

func (*ListResponse) GetMoves 

func (x *ListResponse) GetMoves() []*RecordMove

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type MoveArchive 

type MoveArchive struct {
	Moves []*RecordedMove `protobuf:"bytes,1,rep,name=moves,proto3" json:"moves,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveArchive) Descriptor deprecated 

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

Deprecated: Use MoveArchive.ProtoReflect.Descriptor instead.

func (*MoveArchive) GetMoves 

func (x *MoveArchive) GetMoves() []*RecordedMove

func (*MoveArchive) ProtoMessage 

func (*MoveArchive) ProtoMessage()

func (*MoveArchive) ProtoReflect 

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

func (*MoveArchive) Reset 

func (x *MoveArchive) Reset()

func (*MoveArchive) String 

func (x *MoveArchive) String() string

type MoveRequest 

type MoveRequest struct {
	Move *RecordMove `protobuf:"bytes,1,opt,name=move,proto3" json:"move,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveRequest) Descriptor deprecated 

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

Deprecated: Use MoveRequest.ProtoReflect.Descriptor instead.

func (*MoveRequest) GetMove 

func (x *MoveRequest) GetMove() *RecordMove

func (*MoveRequest) ProtoMessage 

func (*MoveRequest) ProtoMessage()

func (*MoveRequest) ProtoReflect 

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

func (*MoveRequest) Reset 

func (x *MoveRequest) Reset()

func (*MoveRequest) String 

func (x *MoveRequest) String() string

type MoveResponse 

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

func (*MoveResponse) Descriptor deprecated 

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

Deprecated: Use MoveResponse.ProtoReflect.Descriptor instead.

func (*MoveResponse) ProtoMessage 

func (*MoveResponse) ProtoMessage()

func (*MoveResponse) ProtoReflect 

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

func (*MoveResponse) Reset 

func (x *MoveResponse) Reset()

func (*MoveResponse) String 

func (x *MoveResponse) String() string

type MoveServiceClient 

type MoveServiceClient interface {
	RecordMove(ctx context.Context, in *MoveRequest, opts ...grpc.CallOption) (*MoveResponse, error)
	ListMoves(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	ClearMove(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error)
}

MoveServiceClient is the client API for MoveService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMoveServiceClient 

func NewMoveServiceClient(cc grpc.ClientConnInterface) MoveServiceClient

type MoveServiceServer 

type MoveServiceServer interface {
	RecordMove(context.Context, *MoveRequest) (*MoveResponse, error)
	ListMoves(context.Context, *ListRequest) (*ListResponse, error)
	ClearMove(context.Context, *ClearRequest) (*ClearResponse, error)
}

MoveServiceServer is the server API for MoveService service.

type Moves 

type Moves struct {
	Moves []*RecordMove `protobuf:"bytes,1,rep,name=moves,proto3" json:"moves,omitempty"`
	// contains filtered or unexported fields
}

func (*Moves) Descriptor deprecated 

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

Deprecated: Use Moves.ProtoReflect.Descriptor instead.

func (*Moves) GetMoves 

func (x *Moves) GetMoves() []*RecordMove

func (*Moves) ProtoMessage 

func (*Moves) ProtoMessage()

func (*Moves) ProtoReflect 

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

func (*Moves) Reset 

func (x *Moves) Reset()

func (*Moves) String 

func (x *Moves) String() string

type RecordMove 

type RecordMove struct {
	InstanceId    int32          `protobuf:"varint,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	FromFolder    int32          `protobuf:"varint,2,opt,name=from_folder,json=fromFolder,proto3" json:"from_folder,omitempty"`
	ToFolder      int32          `protobuf:"varint,3,opt,name=to_folder,json=toFolder,proto3" json:"to_folder,omitempty"`
	MoveDate      int64          `protobuf:"varint,4,opt,name=move_date,json=moveDate,proto3" json:"move_date,omitempty"`
	Record        *proto1.Record `protobuf:"bytes,5,opt,name=record,proto3" json:"record,omitempty"` // DEPRECATED
	BeforeContext *Context       `protobuf:"bytes,6,opt,name=before_context,json=beforeContext,proto3" json:"before_context,omitempty"`
	AfterContext  *Context       `protobuf:"bytes,7,opt,name=after_context,json=afterContext,proto3" json:"after_context,omitempty"`
	LastUpdate    int64          `protobuf:"varint,8,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordMove) Descriptor deprecated 

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

Deprecated: Use RecordMove.ProtoReflect.Descriptor instead.

func (*RecordMove) GetAfterContext 

func (x *RecordMove) GetAfterContext() *Context

func (*RecordMove) GetBeforeContext 

func (x *RecordMove) GetBeforeContext() *Context

func (*RecordMove) GetFromFolder 

func (x *RecordMove) GetFromFolder() int32

func (*RecordMove) GetInstanceId 

func (x *RecordMove) GetInstanceId() int32

func (*RecordMove) GetLastUpdate 

func (x *RecordMove) GetLastUpdate() int64

func (*RecordMove) GetMoveDate 

func (x *RecordMove) GetMoveDate() int64

func (*RecordMove) GetRecord 

func (x *RecordMove) GetRecord() *proto1.Record

func (*RecordMove) GetToFolder 

func (x *RecordMove) GetToFolder() int32

func (*RecordMove) ProtoMessage 

func (*RecordMove) ProtoMessage()

func (*RecordMove) ProtoReflect 

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

func (*RecordMove) Reset 

func (x *RecordMove) Reset()

func (*RecordMove) String 

func (x *RecordMove) String() string

type RecordedMove 

type RecordedMove struct {

	// The record being moved
	InstanceId int32 `protobuf:"varint,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// The time of the move
	MoveTime int64 `protobuf:"varint,2,opt,name=move_time,json=moveTime,proto3" json:"move_time,omitempty"`
	// The eventual destination of the move
	MoveLocation string `protobuf:"bytes,3,opt,name=move_location,json=moveLocation,proto3" json:"move_location,omitempty"`
	// The initial location of the move
	MoveStart string `protobuf:"bytes,4,opt,name=move_start,json=moveStart,proto3" json:"move_start,omitempty"`
	// The rule applied to make the move
	Rule string `protobuf:"bytes,5,opt,name=rule,proto3" json:"rule,omitempty"`
	From int32  `protobuf:"varint,6,opt,name=from,proto3" json:"from,omitempty"`
	To   int32  `protobuf:"varint,7,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordedMove) Descriptor deprecated 

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

Deprecated: Use RecordedMove.ProtoReflect.Descriptor instead.

func (*RecordedMove) GetFrom 

func (x *RecordedMove) GetFrom() int32

func (*RecordedMove) GetInstanceId 

func (x *RecordedMove) GetInstanceId() int32

func (*RecordedMove) GetMoveLocation 

func (x *RecordedMove) GetMoveLocation() string

func (*RecordedMove) GetMoveStart 

func (x *RecordedMove) GetMoveStart() string

func (*RecordedMove) GetMoveTime 

func (x *RecordedMove) GetMoveTime() int64

func (*RecordedMove) GetRule 

func (x *RecordedMove) GetRule() string

func (*RecordedMove) GetTo 

func (x *RecordedMove) GetTo() int32

func (*RecordedMove) ProtoMessage 

func (*RecordedMove) ProtoMessage()

func (*RecordedMove) ProtoReflect 

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

func (*RecordedMove) Reset 

func (x *RecordedMove) Reset()

func (*RecordedMove) String 

func (x *RecordedMove) String() string

type UnimplementedMoveServiceServer 

type UnimplementedMoveServiceServer struct {
}

UnimplementedMoveServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMoveServiceServer) ClearMove 

func (*UnimplementedMoveServiceServer) ClearMove(context.Context, *ClearRequest) (*ClearResponse, error)

func (*UnimplementedMoveServiceServer) ListMoves 

func (*UnimplementedMoveServiceServer) ListMoves(context.Context, *ListRequest) (*ListResponse, error)

func (*UnimplementedMoveServiceServer) RecordMove 

func (*UnimplementedMoveServiceServer) RecordMove(context.Context, *MoveRequest) (*MoveResponse, error)

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.