pb

package
v0.0.0-...-b66f058 Latest Latest
Warning

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

Go to latest
Published: Dec 30, 2025 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AuthService_Login_FullMethodName        = "/auth.AuthService/Login"
	AuthService_RefreshToken_FullMethodName = "/auth.AuthService/RefreshToken"
	AuthService_Logout_FullMethodName       = "/auth.AuthService/Logout"
)
View Source
const (
	SyncService_SyncUp_FullMethodName       = "/sync.SyncService/SyncUp"
	SyncService_SyncDown_FullMethodName     = "/sync.SyncService/SyncDown"
	SyncService_SyncUpRescue_FullMethodName = "/sync.SyncService/SyncUpRescue"
)
View Source
const (
	MessageService_SendMessage_FullMethodName = "/sync.MessageService/SendMessage"
)

Variables

View Source
var (
	TaskResult_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "SUCCESS",
		2: "ERROR",
	}
	TaskResult_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"SUCCESS":            1,
		"ERROR":              2,
	}
)

Enum value maps for TaskResult_Status.

View Source
var AuthService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "auth.AuthService",
	HandlerType: (*AuthServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Login",
			Handler:    _AuthService_Login_Handler,
		},
		{
			MethodName: "RefreshToken",
			Handler:    _AuthService_RefreshToken_Handler,
		},
		{
			MethodName: "Logout",
			Handler:    _AuthService_Logout_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "public/auth.proto",
}

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

View Source
var File_public_auth_proto protoreflect.FileDescriptor
View Source
var File_public_message_proto protoreflect.FileDescriptor
View Source
var File_public_sync_proto protoreflect.FileDescriptor
View Source
var File_public_syncrow_proto protoreflect.FileDescriptor
View Source
var MessageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sync.MessageService",
	HandlerType: (*MessageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendMessage",
			Handler:    _MessageService_SendMessage_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "public/message.proto",
}

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

View Source
var SyncService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sync.SyncService",
	HandlerType: (*SyncServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SyncUp",
			Handler:    _SyncService_SyncUp_Handler,
		},
		{
			MethodName: "SyncDown",
			Handler:    _SyncService_SyncDown_Handler,
		},
		{
			MethodName: "SyncUpRescue",
			Handler:    _SyncService_SyncUpRescue_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "public/sync.proto",
}

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

Functions

func RegisterAuthServiceServer

func RegisterAuthServiceServer(s grpc.ServiceRegistrar, srv AuthServiceServer)

func RegisterMessageServiceServer

func RegisterMessageServiceServer(s grpc.ServiceRegistrar, srv MessageServiceServer)

func RegisterSyncServiceServer

func RegisterSyncServiceServer(s grpc.ServiceRegistrar, srv SyncServiceServer)

Types

type AuthServiceClient

type AuthServiceClient interface {
	// Permet à un utilisateur de se connecter avec son email et son mot de passe.
	Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error)
	// Permet de rafraîchir un jeton d'accès expiré en utilisant un jeton de rafraîchissement.
	RefreshToken(ctx context.Context, in *RefreshTokenRequest, opts ...grpc.CallOption) (*RefreshTokenResponse, error)
	// Permet à un utilisateur de se déconnecter, invalidant ses jetons côté serveur.
	Logout(ctx context.Context, in *LogoutRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

AuthServiceClient is the client API for AuthService 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.

AuthService définit les points d'entrée RPC pour l'authentification.

type AuthServiceServer

type AuthServiceServer interface {
	// Permet à un utilisateur de se connecter avec son email et son mot de passe.
	Login(context.Context, *LoginRequest) (*LoginResponse, error)
	// Permet de rafraîchir un jeton d'accès expiré en utilisant un jeton de rafraîchissement.
	RefreshToken(context.Context, *RefreshTokenRequest) (*RefreshTokenResponse, error)
	// Permet à un utilisateur de se déconnecter, invalidant ses jetons côté serveur.
	Logout(context.Context, *LogoutRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

AuthServiceServer is the server API for AuthService service. All implementations must embed UnimplementedAuthServiceServer for forward compatibility.

AuthService définit les points d'entrée RPC pour l'authentification.

type LoginRequest

type LoginRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*LoginRequest) ClearEmail

func (x *LoginRequest) ClearEmail()

func (*LoginRequest) ClearPassword

func (x *LoginRequest) ClearPassword()

func (*LoginRequest) GetEmail

func (x *LoginRequest) GetEmail() string

func (*LoginRequest) GetPassword

func (x *LoginRequest) GetPassword() string

func (*LoginRequest) HasEmail

func (x *LoginRequest) HasEmail() bool

func (*LoginRequest) HasPassword

func (x *LoginRequest) HasPassword() bool

func (*LoginRequest) ProtoMessage

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) ProtoReflect

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

func (*LoginRequest) Reset

func (x *LoginRequest) Reset()

func (*LoginRequest) SetEmail

func (x *LoginRequest) SetEmail(v string)

func (*LoginRequest) SetPassword

func (x *LoginRequest) SetPassword(v string)

func (*LoginRequest) String

func (x *LoginRequest) String() string

type LoginRequest_builder

type LoginRequest_builder struct {
	Email    *string
	Password *string
	// contains filtered or unexported fields
}

func (LoginRequest_builder) Build

func (b0 LoginRequest_builder) Build() *LoginRequest

type LoginResponse

type LoginResponse struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*LoginResponse) ClearAccessToken

func (x *LoginResponse) ClearAccessToken()

func (*LoginResponse) ClearRefreshToken

func (x *LoginResponse) ClearRefreshToken()

func (*LoginResponse) ClearUserId

func (x *LoginResponse) ClearUserId()

func (*LoginResponse) GetAccessToken

func (x *LoginResponse) GetAccessToken() string

func (*LoginResponse) GetRefreshToken

func (x *LoginResponse) GetRefreshToken() string

func (*LoginResponse) GetUserId

func (x *LoginResponse) GetUserId() string

func (*LoginResponse) HasAccessToken

func (x *LoginResponse) HasAccessToken() bool

func (*LoginResponse) HasRefreshToken

func (x *LoginResponse) HasRefreshToken() bool

func (*LoginResponse) HasUserId

func (x *LoginResponse) HasUserId() bool

func (*LoginResponse) ProtoMessage

func (*LoginResponse) ProtoMessage()

func (*LoginResponse) ProtoReflect

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

func (*LoginResponse) Reset

func (x *LoginResponse) Reset()

func (*LoginResponse) SetAccessToken

func (x *LoginResponse) SetAccessToken(v string)

func (*LoginResponse) SetRefreshToken

func (x *LoginResponse) SetRefreshToken(v string)

func (*LoginResponse) SetUserId

func (x *LoginResponse) SetUserId(v string)

func (*LoginResponse) String

func (x *LoginResponse) String() string

type LoginResponse_builder

type LoginResponse_builder struct {

	// L'ID de l'utilisateur
	UserId *string
	// Le jeton d'accès à courte durée de vie (ex: 15 minutes).
	AccessToken *string
	// Le jeton de rafraîchissement à longue durée de vie (ex: 30 jours).
	RefreshToken *string
	// contains filtered or unexported fields
}

func (LoginResponse_builder) Build

type LogoutRequest

type LogoutRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*LogoutRequest) ClearRefreshToken

func (x *LogoutRequest) ClearRefreshToken()

func (*LogoutRequest) GetRefreshToken

func (x *LogoutRequest) GetRefreshToken() string

func (*LogoutRequest) HasRefreshToken

func (x *LogoutRequest) HasRefreshToken() bool

func (*LogoutRequest) ProtoMessage

func (*LogoutRequest) ProtoMessage()

func (*LogoutRequest) ProtoReflect

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

func (*LogoutRequest) Reset

func (x *LogoutRequest) Reset()

func (*LogoutRequest) SetRefreshToken

func (x *LogoutRequest) SetRefreshToken(v string)

func (*LogoutRequest) String

func (x *LogoutRequest) String() string

type LogoutRequest_builder

type LogoutRequest_builder struct {
	RefreshToken *string
	// contains filtered or unexported fields
}

func (LogoutRequest_builder) Build

type MessageRequest

type MessageRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*MessageRequest) ClearMessage

func (x *MessageRequest) ClearMessage()

func (*MessageRequest) GetMessage

func (x *MessageRequest) GetMessage() string

func (*MessageRequest) HasMessage

func (x *MessageRequest) HasMessage() bool

func (*MessageRequest) ProtoMessage

func (*MessageRequest) ProtoMessage()

func (*MessageRequest) ProtoReflect

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

func (*MessageRequest) Reset

func (x *MessageRequest) Reset()

func (*MessageRequest) SetMessage

func (x *MessageRequest) SetMessage(v string)

func (*MessageRequest) String

func (x *MessageRequest) String() string

type MessageRequest_builder

type MessageRequest_builder struct {
	Message *string
	// contains filtered or unexported fields
}

func (MessageRequest_builder) Build

type MessageResponse

type MessageResponse struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*MessageResponse) ClearMessage

func (x *MessageResponse) ClearMessage()

func (*MessageResponse) GetMessage

func (x *MessageResponse) GetMessage() string

func (*MessageResponse) HasMessage

func (x *MessageResponse) HasMessage() bool

func (*MessageResponse) ProtoMessage

func (*MessageResponse) ProtoMessage()

func (*MessageResponse) ProtoReflect

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

func (*MessageResponse) Reset

func (x *MessageResponse) Reset()

func (*MessageResponse) SetMessage

func (x *MessageResponse) SetMessage(v string)

func (*MessageResponse) String

func (x *MessageResponse) String() string

type MessageResponse_builder

type MessageResponse_builder struct {
	Message *string
	// contains filtered or unexported fields
}

func (MessageResponse_builder) Build

type MessageServiceClient

type MessageServiceClient interface {
	SendMessage(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageResponse, error)
}

MessageServiceClient is the client API for MessageService 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 MessageServiceServer

type MessageServiceServer interface {
	SendMessage(context.Context, *MessageRequest) (*MessageResponse, error)
	// contains filtered or unexported methods
}

MessageServiceServer is the server API for MessageService service. All implementations must embed UnimplementedMessageServiceServer for forward compatibility.

type RefreshTokenRequest

type RefreshTokenRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*RefreshTokenRequest) ClearRefreshToken

func (x *RefreshTokenRequest) ClearRefreshToken()

func (*RefreshTokenRequest) GetRefreshToken

func (x *RefreshTokenRequest) GetRefreshToken() string

func (*RefreshTokenRequest) HasRefreshToken

func (x *RefreshTokenRequest) HasRefreshToken() bool

func (*RefreshTokenRequest) ProtoMessage

func (*RefreshTokenRequest) ProtoMessage()

func (*RefreshTokenRequest) ProtoReflect

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

func (*RefreshTokenRequest) Reset

func (x *RefreshTokenRequest) Reset()

func (*RefreshTokenRequest) SetRefreshToken

func (x *RefreshTokenRequest) SetRefreshToken(v string)

func (*RefreshTokenRequest) String

func (x *RefreshTokenRequest) String() string

type RefreshTokenRequest_builder

type RefreshTokenRequest_builder struct {
	RefreshToken *string
	// contains filtered or unexported fields
}

func (RefreshTokenRequest_builder) Build

type RefreshTokenResponse

type RefreshTokenResponse struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*RefreshTokenResponse) ClearAccessToken

func (x *RefreshTokenResponse) ClearAccessToken()

func (*RefreshTokenResponse) ClearRefreshToken

func (x *RefreshTokenResponse) ClearRefreshToken()

func (*RefreshTokenResponse) GetAccessToken

func (x *RefreshTokenResponse) GetAccessToken() string

func (*RefreshTokenResponse) GetRefreshToken

func (x *RefreshTokenResponse) GetRefreshToken() string

func (*RefreshTokenResponse) HasAccessToken

func (x *RefreshTokenResponse) HasAccessToken() bool

func (*RefreshTokenResponse) HasRefreshToken

func (x *RefreshTokenResponse) HasRefreshToken() bool

func (*RefreshTokenResponse) ProtoMessage

func (*RefreshTokenResponse) ProtoMessage()

func (*RefreshTokenResponse) ProtoReflect

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

func (*RefreshTokenResponse) Reset

func (x *RefreshTokenResponse) Reset()

func (*RefreshTokenResponse) SetAccessToken

func (x *RefreshTokenResponse) SetAccessToken(v string)

func (*RefreshTokenResponse) SetRefreshToken

func (x *RefreshTokenResponse) SetRefreshToken(v string)

func (*RefreshTokenResponse) String

func (x *RefreshTokenResponse) String() string

type RefreshTokenResponse_builder

type RefreshTokenResponse_builder struct {
	AccessToken *string
	// Le nouveau jeton de rafraîchissement à longue durée de vie.
	RefreshToken *string
	// contains filtered or unexported fields
}

func (RefreshTokenResponse_builder) Build

type SyncDownOperation

type SyncDownOperation struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

Représente une opération de synchronisation descendante unique. L'utilisation de `oneof` garantit qu'une opération est soit un upsert, soit un delete.

func (*SyncDownOperation) ClearDeleted

func (x *SyncDownOperation) ClearDeleted()

func (*SyncDownOperation) ClearEntityId

func (x *SyncDownOperation) ClearEntityId()

func (*SyncDownOperation) ClearPayload

func (x *SyncDownOperation) ClearPayload()

func (*SyncDownOperation) ClearUpdateMask

func (x *SyncDownOperation) ClearUpdateMask()

func (*SyncDownOperation) ClearUpdatedAt

func (x *SyncDownOperation) ClearUpdatedAt()

func (*SyncDownOperation) GetDeleted

func (x *SyncDownOperation) GetDeleted() bool

func (*SyncDownOperation) GetEntityId

func (x *SyncDownOperation) GetEntityId() string

func (*SyncDownOperation) GetPayload

func (x *SyncDownOperation) GetPayload() *anypb.Any

func (*SyncDownOperation) GetUpdateMask

func (x *SyncDownOperation) GetUpdateMask() *fieldmaskpb.FieldMask

func (*SyncDownOperation) GetUpdatedAt

func (x *SyncDownOperation) GetUpdatedAt() *timestamppb.Timestamp

func (*SyncDownOperation) HasDeleted

func (x *SyncDownOperation) HasDeleted() bool

func (*SyncDownOperation) HasEntityId

func (x *SyncDownOperation) HasEntityId() bool

func (*SyncDownOperation) HasPayload

func (x *SyncDownOperation) HasPayload() bool

func (*SyncDownOperation) HasUpdateMask

func (x *SyncDownOperation) HasUpdateMask() bool

func (*SyncDownOperation) HasUpdatedAt

func (x *SyncDownOperation) HasUpdatedAt() bool

func (*SyncDownOperation) ProtoMessage

func (*SyncDownOperation) ProtoMessage()

func (*SyncDownOperation) ProtoReflect

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

func (*SyncDownOperation) Reset

func (x *SyncDownOperation) Reset()

func (*SyncDownOperation) SetDeleted

func (x *SyncDownOperation) SetDeleted(v bool)

func (*SyncDownOperation) SetEntityId

func (x *SyncDownOperation) SetEntityId(v string)

func (*SyncDownOperation) SetPayload

func (x *SyncDownOperation) SetPayload(v *anypb.Any)

func (*SyncDownOperation) SetUpdateMask

func (x *SyncDownOperation) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*SyncDownOperation) SetUpdatedAt

func (x *SyncDownOperation) SetUpdatedAt(v *timestamppb.Timestamp)

func (*SyncDownOperation) String

func (x *SyncDownOperation) String() string

type SyncDownOperation_builder

type SyncDownOperation_builder struct {

	// L'ID de l'entité (clé primaire unique)
	EntityId *string
	// Le payload contient toutes les informations de l'entité tel qu'elle a été stocké
	Payload *anypb.Any
	// la date de création / modification de l'entité. Le client peu s'en servir pour comparer avec
	// sa version, si celle ci est plus ancienne, il ne doit pas l'écraser.
	UpdatedAt *timestamppb.Timestamp
	// Un flag qui indique si l'opération est un delete ou un upsert
	Deleted *bool
	// Les champs qui ont été modifié
	UpdateMask *fieldmaskpb.FieldMask
	// contains filtered or unexported fields
}

func (SyncDownOperation_builder) Build

type SyncDownRequest

type SyncDownRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*SyncDownRequest) ClearDatabaseId

func (x *SyncDownRequest) ClearDatabaseId()

func (*SyncDownRequest) ClearLastSync

func (x *SyncDownRequest) ClearLastSync()

func (*SyncDownRequest) GetDatabaseId

func (x *SyncDownRequest) GetDatabaseId() string

func (*SyncDownRequest) GetLastSync

func (x *SyncDownRequest) GetLastSync() *timestamppb.Timestamp

func (*SyncDownRequest) HasDatabaseId

func (x *SyncDownRequest) HasDatabaseId() bool

func (*SyncDownRequest) HasLastSync

func (x *SyncDownRequest) HasLastSync() bool

func (*SyncDownRequest) ProtoMessage

func (*SyncDownRequest) ProtoMessage()

func (*SyncDownRequest) ProtoReflect

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

func (*SyncDownRequest) Reset

func (x *SyncDownRequest) Reset()

func (*SyncDownRequest) SetDatabaseId

func (x *SyncDownRequest) SetDatabaseId(v string)

func (*SyncDownRequest) SetLastSync

func (x *SyncDownRequest) SetLastSync(v *timestamppb.Timestamp)

func (*SyncDownRequest) String

func (x *SyncDownRequest) String() string

type SyncDownRequest_builder

type SyncDownRequest_builder struct {

	// L'uuid de la base local
	DatabaseId *string
	// Le timestamp de la dernière synchro.
	LastSync *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (SyncDownRequest_builder) Build

type SyncDownResponse

type SyncDownResponse struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*SyncDownResponse) ClearHasMore

func (x *SyncDownResponse) ClearHasMore()

func (*SyncDownResponse) ClearNextSync

func (x *SyncDownResponse) ClearNextSync()

func (*SyncDownResponse) GetHasMore

func (x *SyncDownResponse) GetHasMore() bool

func (*SyncDownResponse) GetNextSync

func (x *SyncDownResponse) GetNextSync() *timestamppb.Timestamp

func (*SyncDownResponse) GetOperations

func (x *SyncDownResponse) GetOperations() []*SyncDownOperation

func (*SyncDownResponse) HasHasMore

func (x *SyncDownResponse) HasHasMore() bool

func (*SyncDownResponse) HasNextSync

func (x *SyncDownResponse) HasNextSync() bool

func (*SyncDownResponse) ProtoMessage

func (*SyncDownResponse) ProtoMessage()

func (*SyncDownResponse) ProtoReflect

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

func (*SyncDownResponse) Reset

func (x *SyncDownResponse) Reset()

func (*SyncDownResponse) SetHasMore

func (x *SyncDownResponse) SetHasMore(v bool)

func (*SyncDownResponse) SetNextSync

func (x *SyncDownResponse) SetNextSync(v *timestamppb.Timestamp)

func (*SyncDownResponse) SetOperations

func (x *SyncDownResponse) SetOperations(v []*SyncDownOperation)

func (*SyncDownResponse) String

func (x *SyncDownResponse) String() string

type SyncDownResponse_builder

type SyncDownResponse_builder struct {
	NextSync *timestamppb.Timestamp
	// Une liste ordonnée d'opérations à exécuter par le client.
	// L'ordre est crucial pour maintenir la cohérence des données.
	Operations []*SyncDownOperation
	// flag qui permet de dire au client que la réponse est incomplete
	// et qu'il doit continuer de sync down
	HasMore *bool
	// contains filtered or unexported fields
}

func (SyncDownResponse_builder) Build

type SyncRowStorage

type SyncRowStorage struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*SyncRowStorage) ClearDeleted

func (x *SyncRowStorage) ClearDeleted()

func (*SyncRowStorage) ClearEntityId

func (x *SyncRowStorage) ClearEntityId()

func (*SyncRowStorage) ClearTaskPayload

func (x *SyncRowStorage) ClearTaskPayload()

func (*SyncRowStorage) ClearUpdateMask

func (x *SyncRowStorage) ClearUpdateMask()

func (*SyncRowStorage) ClearUpdatedAt

func (x *SyncRowStorage) ClearUpdatedAt()

func (*SyncRowStorage) GetDeleted

func (x *SyncRowStorage) GetDeleted() bool

func (*SyncRowStorage) GetEntityId

func (x *SyncRowStorage) GetEntityId() string

func (*SyncRowStorage) GetTaskPayload

func (x *SyncRowStorage) GetTaskPayload() *anypb.Any

func (*SyncRowStorage) GetUpdateMask

func (x *SyncRowStorage) GetUpdateMask() *fieldmaskpb.FieldMask

func (*SyncRowStorage) GetUpdatedAt

func (x *SyncRowStorage) GetUpdatedAt() *timestamppb.Timestamp

func (*SyncRowStorage) HasDeleted

func (x *SyncRowStorage) HasDeleted() bool

func (*SyncRowStorage) HasEntityId

func (x *SyncRowStorage) HasEntityId() bool

func (*SyncRowStorage) HasTaskPayload

func (x *SyncRowStorage) HasTaskPayload() bool

func (*SyncRowStorage) HasUpdateMask

func (x *SyncRowStorage) HasUpdateMask() bool

func (*SyncRowStorage) HasUpdatedAt

func (x *SyncRowStorage) HasUpdatedAt() bool

func (*SyncRowStorage) ProtoMessage

func (*SyncRowStorage) ProtoMessage()

func (*SyncRowStorage) ProtoReflect

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

func (*SyncRowStorage) Reset

func (x *SyncRowStorage) Reset()

func (*SyncRowStorage) SetDeleted

func (x *SyncRowStorage) SetDeleted(v bool)

func (*SyncRowStorage) SetEntityId

func (x *SyncRowStorage) SetEntityId(v string)

func (*SyncRowStorage) SetTaskPayload

func (x *SyncRowStorage) SetTaskPayload(v *anypb.Any)

func (*SyncRowStorage) SetUpdateMask

func (x *SyncRowStorage) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*SyncRowStorage) SetUpdatedAt

func (x *SyncRowStorage) SetUpdatedAt(v *timestamppb.Timestamp)

func (*SyncRowStorage) String

func (x *SyncRowStorage) String() string

type SyncRowStorage_builder

type SyncRowStorage_builder struct {
	UpdatedAt   *timestamppb.Timestamp
	EntityId    *string
	Deleted     *bool
	TaskPayload *anypb.Any
	UpdateMask  *fieldmaskpb.FieldMask
	// contains filtered or unexported fields
}

func (SyncRowStorage_builder) Build

type SyncServiceClient

type SyncServiceClient interface {
	// Envoie un lot de tâches au serveur (sync up)
	SyncUp(ctx context.Context, in *SyncUpRequest, opts ...grpc.CallOption) (*SyncUpResponse, error)
	// Récupère les mises à jour depuis le serveur (sync down)
	SyncDown(ctx context.Context, in *SyncDownRequest, opts ...grpc.CallOption) (*SyncDownResponse, error)
	// Envoi les tâches manquante lorsque le serveur est en mode rescue
	SyncUpRescue(ctx context.Context, in *SyncUpRequestRescue, opts ...grpc.CallOption) (*SyncUpResponse, error)
}

SyncServiceClient is the client API for SyncService 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.

SyncService définit les points d'entrée RPC pour la synchronisation.

type SyncServiceServer

type SyncServiceServer interface {
	// Envoie un lot de tâches au serveur (sync up)
	SyncUp(context.Context, *SyncUpRequest) (*SyncUpResponse, error)
	// Récupère les mises à jour depuis le serveur (sync down)
	SyncDown(context.Context, *SyncDownRequest) (*SyncDownResponse, error)
	// Envoi les tâches manquante lorsque le serveur est en mode rescue
	SyncUpRescue(context.Context, *SyncUpRequestRescue) (*SyncUpResponse, error)
	// contains filtered or unexported methods
}

SyncServiceServer is the server API for SyncService service. All implementations must embed UnimplementedSyncServiceServer for forward compatibility.

SyncService définit les points d'entrée RPC pour la synchronisation.

type SyncTask

type SyncTask struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

Représente une opération de modification unique à synchroniser (sync up). Basé sur la classe Dart SyncTask.

func (*SyncTask) ClearClientTaskId

func (x *SyncTask) ClearClientTaskId()

func (*SyncTask) ClearEntityId

func (x *SyncTask) ClearEntityId()

func (*SyncTask) ClearIsDelete

func (x *SyncTask) ClearIsDelete()

func (*SyncTask) ClearPayload

func (x *SyncTask) ClearPayload()

func (*SyncTask) ClearUpdateMask

func (x *SyncTask) ClearUpdateMask()

func (*SyncTask) ClearUpdatedAt

func (x *SyncTask) ClearUpdatedAt()

func (*SyncTask) GetClientTaskId

func (x *SyncTask) GetClientTaskId() string

func (*SyncTask) GetEntityId

func (x *SyncTask) GetEntityId() string

func (*SyncTask) GetIsDelete

func (x *SyncTask) GetIsDelete() bool

func (*SyncTask) GetPayload

func (x *SyncTask) GetPayload() *anypb.Any

func (*SyncTask) GetUpdateMask

func (x *SyncTask) GetUpdateMask() *fieldmaskpb.FieldMask

func (*SyncTask) GetUpdatedAt

func (x *SyncTask) GetUpdatedAt() *timestamppb.Timestamp

func (*SyncTask) HasClientTaskId

func (x *SyncTask) HasClientTaskId() bool

func (*SyncTask) HasEntityId

func (x *SyncTask) HasEntityId() bool

func (*SyncTask) HasIsDelete

func (x *SyncTask) HasIsDelete() bool

func (*SyncTask) HasPayload

func (x *SyncTask) HasPayload() bool

func (*SyncTask) HasUpdateMask

func (x *SyncTask) HasUpdateMask() bool

func (*SyncTask) HasUpdatedAt

func (x *SyncTask) HasUpdatedAt() bool

func (*SyncTask) ProtoMessage

func (*SyncTask) ProtoMessage()

func (*SyncTask) ProtoReflect

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

func (*SyncTask) Reset

func (x *SyncTask) Reset()

func (*SyncTask) SetClientTaskId

func (x *SyncTask) SetClientTaskId(v string)

func (*SyncTask) SetEntityId

func (x *SyncTask) SetEntityId(v string)

func (*SyncTask) SetIsDelete

func (x *SyncTask) SetIsDelete(v bool)

func (*SyncTask) SetPayload

func (x *SyncTask) SetPayload(v *anypb.Any)

func (*SyncTask) SetUpdateMask

func (x *SyncTask) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*SyncTask) SetUpdatedAt

func (x *SyncTask) SetUpdatedAt(v *timestamppb.Timestamp)

func (*SyncTask) String

func (x *SyncTask) String() string

type SyncTask_builder

type SyncTask_builder struct {

	// L'ID local de la tâche (le client s'en sert pour matcher la réponse).
	ClientTaskId *string
	// Date de modification du payload
	UpdatedAt *timestamppb.Timestamp
	// L'ID de l'entité (clé primaire de la table)
	EntityId *string
	// Le payload de l'entité, encapsulé dans un message Any.
	// Permet de transporter n'importe quel type de message Protobuf.
	// peut avoir une value vide mais un typeURL pour les tache delete
	Payload *anypb.Any
	// indique si c'est une opération de deletion
	IsDelete *bool
	// On ne transfert que les modification depuis un objet anterieur.
	// Le update_mask permet de connaitre quels sont les modifications
	// apporté à l'objet. Si un champ est null, le mask permet de savoir
	// si le champ est passé à null ou si il reste inchangé par rapport à l'existant
	UpdateMask *fieldmaskpb.FieldMask
	// contains filtered or unexported fields
}

func (SyncTask_builder) Build

func (b0 SyncTask_builder) Build() *SyncTask

type SyncUpRequest

type SyncUpRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*SyncUpRequest) ClearDatabaseId

func (x *SyncUpRequest) ClearDatabaseId()

func (*SyncUpRequest) GetDatabaseId

func (x *SyncUpRequest) GetDatabaseId() string

func (*SyncUpRequest) GetTasks

func (x *SyncUpRequest) GetTasks() []*SyncTask

func (*SyncUpRequest) HasDatabaseId

func (x *SyncUpRequest) HasDatabaseId() bool

func (*SyncUpRequest) ProtoMessage

func (*SyncUpRequest) ProtoMessage()

func (*SyncUpRequest) ProtoReflect

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

func (*SyncUpRequest) Reset

func (x *SyncUpRequest) Reset()

func (*SyncUpRequest) SetDatabaseId

func (x *SyncUpRequest) SetDatabaseId(v string)

func (*SyncUpRequest) SetTasks

func (x *SyncUpRequest) SetTasks(v []*SyncTask)

func (*SyncUpRequest) String

func (x *SyncUpRequest) String() string

type SyncUpRequestRescue

type SyncUpRequestRescue struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*SyncUpRequestRescue) ClearHasMore

func (x *SyncUpRequestRescue) ClearHasMore()

func (*SyncUpRequestRescue) ClearRequest

func (x *SyncUpRequestRescue) ClearRequest()

func (*SyncUpRequestRescue) GetHasMore

func (x *SyncUpRequestRescue) GetHasMore() bool

func (*SyncUpRequestRescue) GetRequest

func (x *SyncUpRequestRescue) GetRequest() *SyncUpRequest

func (*SyncUpRequestRescue) HasHasMore

func (x *SyncUpRequestRescue) HasHasMore() bool

func (*SyncUpRequestRescue) HasRequest

func (x *SyncUpRequestRescue) HasRequest() bool

func (*SyncUpRequestRescue) ProtoMessage

func (*SyncUpRequestRescue) ProtoMessage()

func (*SyncUpRequestRescue) ProtoReflect

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

func (*SyncUpRequestRescue) Reset

func (x *SyncUpRequestRescue) Reset()

func (*SyncUpRequestRescue) SetHasMore

func (x *SyncUpRequestRescue) SetHasMore(v bool)

func (*SyncUpRequestRescue) SetRequest

func (x *SyncUpRequestRescue) SetRequest(v *SyncUpRequest)

func (*SyncUpRequestRescue) String

func (x *SyncUpRequestRescue) String() string

type SyncUpRequestRescue_builder

type SyncUpRequestRescue_builder struct {

	// la synctask original
	Request *SyncUpRequest
	// indique au serveur si il y a encore des données à synchroniser
	HasMore *bool
	// contains filtered or unexported fields
}

func (SyncUpRequestRescue_builder) Build

type SyncUpRequest_builder

type SyncUpRequest_builder struct {
	Tasks []*SyncTask
	// L'identifiant de la base de donnée local
	DatabaseId *string
	// contains filtered or unexported fields
}

func (SyncUpRequest_builder) Build

type SyncUpResponse

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

func (*SyncUpResponse) ClearMissingDataUntil

func (x *SyncUpResponse) ClearMissingDataUntil()

func (*SyncUpResponse) GetMissingDataUntil

func (x *SyncUpResponse) GetMissingDataUntil() *timestamppb.Timestamp

func (*SyncUpResponse) GetResults

func (x *SyncUpResponse) GetResults() []*TaskResult

func (*SyncUpResponse) HasMissingDataUntil

func (x *SyncUpResponse) HasMissingDataUntil() bool

func (*SyncUpResponse) ProtoMessage

func (*SyncUpResponse) ProtoMessage()

func (*SyncUpResponse) ProtoReflect

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

func (*SyncUpResponse) Reset

func (x *SyncUpResponse) Reset()

func (*SyncUpResponse) SetMissingDataUntil

func (x *SyncUpResponse) SetMissingDataUntil(v *timestamppb.Timestamp)

func (*SyncUpResponse) SetResults

func (x *SyncUpResponse) SetResults(v []*TaskResult)

func (*SyncUpResponse) String

func (x *SyncUpResponse) String() string

type SyncUpResponse_builder

type SyncUpResponse_builder struct {
	Results []*TaskResult
	// Si le champs missingDataUntil est remplis, c'est que le serveur a un trou dans la chronologie
	// des données. C'est le rescue mode après une restoration d'un backup.
	MissingDataUntil *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (SyncUpResponse_builder) Build

type TaskResult

type TaskResult struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

TaskResult représente le résultat du traitement d'une seule SyncTask.

func (*TaskResult) ClearClientTaskId

func (x *TaskResult) ClearClientTaskId()

func (*TaskResult) ClearErrorMessage

func (x *TaskResult) ClearErrorMessage()

func (*TaskResult) ClearStatus

func (x *TaskResult) ClearStatus()

func (*TaskResult) GetClientTaskId

func (x *TaskResult) GetClientTaskId() string

func (*TaskResult) GetErrorMessage

func (x *TaskResult) GetErrorMessage() string

func (*TaskResult) GetStatus

func (x *TaskResult) GetStatus() TaskResult_Status

func (*TaskResult) HasClientTaskId

func (x *TaskResult) HasClientTaskId() bool

func (*TaskResult) HasErrorMessage

func (x *TaskResult) HasErrorMessage() bool

func (*TaskResult) HasStatus

func (x *TaskResult) HasStatus() bool

func (*TaskResult) ProtoMessage

func (*TaskResult) ProtoMessage()

func (*TaskResult) ProtoReflect

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

func (*TaskResult) Reset

func (x *TaskResult) Reset()

func (*TaskResult) SetClientTaskId

func (x *TaskResult) SetClientTaskId(v string)

func (*TaskResult) SetErrorMessage

func (x *TaskResult) SetErrorMessage(v string)

func (*TaskResult) SetStatus

func (x *TaskResult) SetStatus(v TaskResult_Status)

func (*TaskResult) String

func (x *TaskResult) String() string

type TaskResult_Status

type TaskResult_Status int32
const (
	TaskResult_STATUS_UNSPECIFIED TaskResult_Status = 0
	// La task est inseré avec succés
	TaskResult_SUCCESS TaskResult_Status = 1
	// Erreur temporaire, le client doit réessayer plus tard.
	TaskResult_ERROR TaskResult_Status = 2
)

func (TaskResult_Status) Descriptor

func (TaskResult_Status) Enum

func (TaskResult_Status) Number

func (TaskResult_Status) String

func (x TaskResult_Status) String() string

func (TaskResult_Status) Type

type TaskResult_builder

type TaskResult_builder struct {
	ClientTaskId *string
	Status       *TaskResult_Status
	// Message d'erreur, pertinent seulement si status == ERROR
	ErrorMessage *string
	// contains filtered or unexported fields
}

func (TaskResult_builder) Build

func (b0 TaskResult_builder) Build() *TaskResult

type UnimplementedAuthServiceServer

type UnimplementedAuthServiceServer struct{}

UnimplementedAuthServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAuthServiceServer) Login

func (UnimplementedAuthServiceServer) Logout

func (UnimplementedAuthServiceServer) RefreshToken

type UnimplementedMessageServiceServer

type UnimplementedMessageServiceServer struct{}

UnimplementedMessageServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedMessageServiceServer) SendMessage

type UnimplementedSyncServiceServer

type UnimplementedSyncServiceServer struct{}

UnimplementedSyncServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedSyncServiceServer) SyncDown

func (UnimplementedSyncServiceServer) SyncUp

func (UnimplementedSyncServiceServer) SyncUpRescue

type UnsafeAuthServiceServer

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

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

type UnsafeMessageServiceServer

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

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

type UnsafeSyncServiceServer

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

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

Jump to

Keyboard shortcuts

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