pb

package
v1.72.0 Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2024 License: AGPL-3.0 Imports: 10 Imported by: 1

Documentation

Overview

Package pb includes protobufs for the badgerauth package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	Record_State_name = map[int32]string{
		0: "CREATED",
	}
	Record_State_value = map[string]int32{
		"CREATED": 0,
	}
)

Enum value maps for Record_State.

View Source 
var File_badgerauth_admin_proto protoreflect.FileDescriptor
View Source 
var File_badgerauth_proto protoreflect.FileDescriptor

Functions

func DRPCRegisterAdminService 

func DRPCRegisterAdminService(mux drpc.Mux, impl DRPCAdminServiceServer) error

func DRPCRegisterReplicationService 

func DRPCRegisterReplicationService(mux drpc.Mux, impl DRPCReplicationServiceServer) error

func Equal 

func Equal(x, y proto.Message) bool

Equal is an alias for proto.Equal.

func Marshal 

func Marshal(m proto.Message) ([]byte, error)

Marshal is an alias for proto.Marshal.

func Unmarshal 

func Unmarshal(b []byte, m proto.Message) error

Unmarshal is an alias for proto.Unmarshal.

Types

type DRPCAdminServiceClient 

type DRPCAdminServiceClient interface {
	DRPCConn() drpc.Conn

	InvalidateRecord(ctx context.Context, in *InvalidateRecordRequest) (*InvalidateRecordResponse, error)
	UnpublishRecord(ctx context.Context, in *UnpublishRecordRequest) (*UnpublishRecordResponse, error)
	DeleteRecord(ctx context.Context, in *DeleteRecordRequest) (*DeleteRecordResponse, error)
}

func NewDRPCAdminServiceClient 

func NewDRPCAdminServiceClient(cc drpc.Conn) DRPCAdminServiceClient

type DRPCAdminServiceDescription 

type DRPCAdminServiceDescription struct{}

func (DRPCAdminServiceDescription) Method 

func (DRPCAdminServiceDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCAdminServiceDescription) NumMethods 

func (DRPCAdminServiceDescription) NumMethods() int

type DRPCAdminServiceServer 

type DRPCAdminServiceServer interface {
	InvalidateRecord(context.Context, *InvalidateRecordRequest) (*InvalidateRecordResponse, error)
	UnpublishRecord(context.Context, *UnpublishRecordRequest) (*UnpublishRecordResponse, error)
	DeleteRecord(context.Context, *DeleteRecordRequest) (*DeleteRecordResponse, error)
}

type DRPCAdminServiceUnimplementedServer 

type DRPCAdminServiceUnimplementedServer struct{}

func (*DRPCAdminServiceUnimplementedServer) DeleteRecord 

func (s *DRPCAdminServiceUnimplementedServer) DeleteRecord(context.Context, *DeleteRecordRequest) (*DeleteRecordResponse, error)

func (*DRPCAdminServiceUnimplementedServer) InvalidateRecord 

func (s *DRPCAdminServiceUnimplementedServer) InvalidateRecord(context.Context, *InvalidateRecordRequest) (*InvalidateRecordResponse, error)

func (*DRPCAdminServiceUnimplementedServer) UnpublishRecord 

func (s *DRPCAdminServiceUnimplementedServer) UnpublishRecord(context.Context, *UnpublishRecordRequest) (*UnpublishRecordResponse, error)

type DRPCAdminService_DeleteRecordStream 

type DRPCAdminService_DeleteRecordStream interface {
	drpc.Stream
	SendAndClose(*DeleteRecordResponse) error
}

type DRPCAdminService_InvalidateRecordStream 

type DRPCAdminService_InvalidateRecordStream interface {
	drpc.Stream
	SendAndClose(*InvalidateRecordResponse) error
}

type DRPCAdminService_UnpublishRecordStream 

type DRPCAdminService_UnpublishRecordStream interface {
	drpc.Stream
	SendAndClose(*UnpublishRecordResponse) error
}

type DRPCReplicationServiceClient 

type DRPCReplicationServiceClient interface {
	DRPCConn() drpc.Conn

	Ping(ctx context.Context, in *PingRequest) (*PingResponse, error)
	Peek(ctx context.Context, in *PeekRequest) (*PeekResponse, error)
	Replicate(ctx context.Context, in *ReplicationRequest) (*ReplicationResponse, error)
}

func NewDRPCReplicationServiceClient 

func NewDRPCReplicationServiceClient(cc drpc.Conn) DRPCReplicationServiceClient

type DRPCReplicationServiceDescription 

type DRPCReplicationServiceDescription struct{}

func (DRPCReplicationServiceDescription) Method 

func (DRPCReplicationServiceDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCReplicationServiceDescription) NumMethods 

func (DRPCReplicationServiceDescription) NumMethods() int

type DRPCReplicationServiceServer 

type DRPCReplicationServiceServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	Peek(context.Context, *PeekRequest) (*PeekResponse, error)
	Replicate(context.Context, *ReplicationRequest) (*ReplicationResponse, error)
}

type DRPCReplicationServiceUnimplementedServer 

type DRPCReplicationServiceUnimplementedServer struct{}

func (*DRPCReplicationServiceUnimplementedServer) Peek 

func (s *DRPCReplicationServiceUnimplementedServer) Peek(context.Context, *PeekRequest) (*PeekResponse, error)

func (*DRPCReplicationServiceUnimplementedServer) Ping 

func (s *DRPCReplicationServiceUnimplementedServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (*DRPCReplicationServiceUnimplementedServer) Replicate 

func (s *DRPCReplicationServiceUnimplementedServer) Replicate(context.Context, *ReplicationRequest) (*ReplicationResponse, error)

type DRPCReplicationService_PeekStream 

type DRPCReplicationService_PeekStream interface {
	drpc.Stream
	SendAndClose(*PeekResponse) error
}

type DRPCReplicationService_PingStream 

type DRPCReplicationService_PingStream interface {
	drpc.Stream
	SendAndClose(*PingResponse) error
}

type DRPCReplicationService_ReplicateStream 

type DRPCReplicationService_ReplicateStream interface {
	drpc.Stream
	SendAndClose(*ReplicationResponse) error
}

type DeleteRecordRequest 

type DeleteRecordRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRecordRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRecordRequest.ProtoReflect.Descriptor instead.

func (*DeleteRecordRequest) GetKey 

func (x *DeleteRecordRequest) GetKey() []byte

func (*DeleteRecordRequest) ProtoMessage 

func (*DeleteRecordRequest) ProtoMessage()

func (*DeleteRecordRequest) ProtoReflect 

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

func (*DeleteRecordRequest) Reset 

func (x *DeleteRecordRequest) Reset()

func (*DeleteRecordRequest) String 

func (x *DeleteRecordRequest) String() string

type DeleteRecordResponse 

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

func (*DeleteRecordResponse) Descriptor deprecated 

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

Deprecated: Use DeleteRecordResponse.ProtoReflect.Descriptor instead.

func (*DeleteRecordResponse) ProtoMessage 

func (*DeleteRecordResponse) ProtoMessage()

func (*DeleteRecordResponse) ProtoReflect 

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

func (*DeleteRecordResponse) Reset 

func (x *DeleteRecordResponse) Reset()

func (*DeleteRecordResponse) String 

func (x *DeleteRecordResponse) String() string

type InvalidateRecordRequest 

type InvalidateRecordRequest struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*InvalidateRecordRequest) Descriptor deprecated 

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

Deprecated: Use InvalidateRecordRequest.ProtoReflect.Descriptor instead.

func (*InvalidateRecordRequest) GetKey 

func (x *InvalidateRecordRequest) GetKey() []byte

func (*InvalidateRecordRequest) GetReason 

func (x *InvalidateRecordRequest) GetReason() string

func (*InvalidateRecordRequest) ProtoMessage 

func (*InvalidateRecordRequest) ProtoMessage()

func (*InvalidateRecordRequest) ProtoReflect 

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

func (*InvalidateRecordRequest) Reset 

func (x *InvalidateRecordRequest) Reset()

func (*InvalidateRecordRequest) String 

func (x *InvalidateRecordRequest) String() string

type InvalidateRecordResponse 

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

func (*InvalidateRecordResponse) Descriptor deprecated 

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

Deprecated: Use InvalidateRecordResponse.ProtoReflect.Descriptor instead.

func (*InvalidateRecordResponse) ProtoMessage 

func (*InvalidateRecordResponse) ProtoMessage()

func (*InvalidateRecordResponse) ProtoReflect 

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

func (*InvalidateRecordResponse) Reset 

func (x *InvalidateRecordResponse) Reset()

func (*InvalidateRecordResponse) String 

func (x *InvalidateRecordResponse) String() string

type PeekRequest 

type PeekRequest struct {
	EncryptionKeyHash []byte `protobuf:"bytes,1,opt,name=encryption_key_hash,json=encryptionKeyHash,proto3" json:"encryption_key_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*PeekRequest) Descriptor deprecated 

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

Deprecated: Use PeekRequest.ProtoReflect.Descriptor instead.

func (*PeekRequest) GetEncryptionKeyHash 

func (x *PeekRequest) GetEncryptionKeyHash() []byte

func (*PeekRequest) ProtoMessage 

func (*PeekRequest) ProtoMessage()

func (*PeekRequest) ProtoReflect 

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

func (*PeekRequest) Reset 

func (x *PeekRequest) Reset()

func (*PeekRequest) String 

func (x *PeekRequest) String() string

type PeekResponse 

type PeekResponse struct {
	Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*PeekResponse) Descriptor deprecated 

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

Deprecated: Use PeekResponse.ProtoReflect.Descriptor instead.

func (*PeekResponse) GetRecord 

func (x *PeekResponse) GetRecord() *Record

func (*PeekResponse) ProtoMessage 

func (*PeekResponse) ProtoMessage()

func (*PeekResponse) ProtoReflect 

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

func (*PeekResponse) Reset 

func (x *PeekResponse) Reset()

func (*PeekResponse) String 

func (x *PeekResponse) String() string

type PingRequest 

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

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {
	NodeId []byte `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetNodeId 

func (x *PingResponse) GetNodeId() []byte

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type Record 

type Record struct {

	// record data
	CreatedAtUnix int64 `protobuf:"varint,1,opt,name=created_at_unix,json=createdAtUnix,proto3" json:"created_at_unix,omitempty"`
	Public        bool  `protobuf:"varint,2,opt,name=public,proto3" json:"public,omitempty"`
	// denormalized information from access grant
	SatelliteAddress string `protobuf:"bytes,3,opt,name=satellite_address,json=satelliteAddress,proto3" json:"satellite_address,omitempty"`
	MacaroonHead     []byte `protobuf:"bytes,4,opt,name=macaroon_head,json=macaroonHead,proto3" json:"macaroon_head,omitempty"`
	ExpiresAtUnix    int64  `protobuf:"varint,5,opt,name=expires_at_unix,json=expiresAtUnix,proto3" json:"expires_at_unix,omitempty"`
	// sensitive data
	EncryptedSecretKey   []byte `protobuf:"bytes,6,opt,name=encrypted_secret_key,json=encryptedSecretKey,proto3" json:"encrypted_secret_key,omitempty"`
	EncryptedAccessGrant []byte `protobuf:"bytes,7,opt,name=encrypted_access_grant,json=encryptedAccessGrant,proto3" json:"encrypted_access_grant,omitempty"`
	// invalidation tracking
	InvalidationReason string `protobuf:"bytes,8,opt,name=invalidation_reason,json=invalidationReason,proto3" json:"invalidation_reason,omitempty"`
	InvalidatedAtUnix  int64  `protobuf:"varint,9,opt,name=invalidated_at_unix,json=invalidatedAtUnix,proto3" json:"invalidated_at_unix,omitempty"`
	// synchronization-related data
	State Record_State `protobuf:"varint,10,opt,name=state,proto3,enum=badgerauth.Record_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetCreatedAtUnix 

func (x *Record) GetCreatedAtUnix() int64

func (*Record) GetEncryptedAccessGrant 

func (x *Record) GetEncryptedAccessGrant() []byte

func (*Record) GetEncryptedSecretKey 

func (x *Record) GetEncryptedSecretKey() []byte

func (*Record) GetExpiresAtUnix 

func (x *Record) GetExpiresAtUnix() int64

func (*Record) GetInvalidatedAtUnix 

func (x *Record) GetInvalidatedAtUnix() int64

func (*Record) GetInvalidationReason 

func (x *Record) GetInvalidationReason() string

func (*Record) GetMacaroonHead 

func (x *Record) GetMacaroonHead() []byte

func (*Record) GetPublic 

func (x *Record) GetPublic() bool

func (*Record) GetSatelliteAddress 

func (x *Record) GetSatelliteAddress() string

func (*Record) GetState 

func (x *Record) GetState() Record_State

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

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

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

type Record_State 

type Record_State int32
const (
	Record_CREATED Record_State = 0
)

func (Record_State) Descriptor 

func (Record_State) Descriptor() protoreflect.EnumDescriptor

func (Record_State) Enum 

func (x Record_State) Enum() *Record_State

func (Record_State) EnumDescriptor deprecated 

func (Record_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Record_State.Descriptor instead.

func (Record_State) Number 

func (x Record_State) Number() protoreflect.EnumNumber

func (Record_State) String 

func (x Record_State) String() string

func (Record_State) Type 

func (Record_State) Type() protoreflect.EnumType

type ReplicationRequest 

type ReplicationRequest struct {
	Entries []*ReplicationRequestEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationRequest) Descriptor deprecated 

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

Deprecated: Use ReplicationRequest.ProtoReflect.Descriptor instead.

func (*ReplicationRequest) GetEntries 

func (x *ReplicationRequest) GetEntries() []*ReplicationRequestEntry

func (*ReplicationRequest) ProtoMessage 

func (*ReplicationRequest) ProtoMessage()

func (*ReplicationRequest) ProtoReflect 

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

func (*ReplicationRequest) Reset 

func (x *ReplicationRequest) Reset()

func (*ReplicationRequest) String 

func (x *ReplicationRequest) String() string

type ReplicationRequestEntry 

type ReplicationRequestEntry struct {
	NodeId []byte `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Clock  uint64 `protobuf:"varint,2,opt,name=clock,proto3" json:"clock,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationRequestEntry) Descriptor deprecated 

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

Deprecated: Use ReplicationRequestEntry.ProtoReflect.Descriptor instead.

func (*ReplicationRequestEntry) GetClock 

func (x *ReplicationRequestEntry) GetClock() uint64

func (*ReplicationRequestEntry) GetNodeId 

func (x *ReplicationRequestEntry) GetNodeId() []byte

func (*ReplicationRequestEntry) ProtoMessage 

func (*ReplicationRequestEntry) ProtoMessage()

func (*ReplicationRequestEntry) ProtoReflect 

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

func (*ReplicationRequestEntry) Reset 

func (x *ReplicationRequestEntry) Reset()

func (*ReplicationRequestEntry) String 

func (x *ReplicationRequestEntry) String() string

type ReplicationResponse 

type ReplicationResponse struct {
	Entries []*ReplicationResponseEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationResponse) Descriptor deprecated 

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

Deprecated: Use ReplicationResponse.ProtoReflect.Descriptor instead.

func (*ReplicationResponse) GetEntries 

func (x *ReplicationResponse) GetEntries() []*ReplicationResponseEntry

func (*ReplicationResponse) ProtoMessage 

func (*ReplicationResponse) ProtoMessage()

func (*ReplicationResponse) ProtoReflect 

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

func (*ReplicationResponse) Reset 

func (x *ReplicationResponse) Reset()

func (*ReplicationResponse) String 

func (x *ReplicationResponse) String() string

type ReplicationResponseEntry 

type ReplicationResponseEntry struct {
	NodeId            []byte  `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	EncryptionKeyHash []byte  `protobuf:"bytes,2,opt,name=encryption_key_hash,json=encryptionKeyHash,proto3" json:"encryption_key_hash,omitempty"`
	Record            *Record `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationResponseEntry) Descriptor deprecated 

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

Deprecated: Use ReplicationResponseEntry.ProtoReflect.Descriptor instead.

func (*ReplicationResponseEntry) GetEncryptionKeyHash 

func (x *ReplicationResponseEntry) GetEncryptionKeyHash() []byte

func (*ReplicationResponseEntry) GetNodeId 

func (x *ReplicationResponseEntry) GetNodeId() []byte

func (*ReplicationResponseEntry) GetRecord 

func (x *ReplicationResponseEntry) GetRecord() *Record

func (*ReplicationResponseEntry) ProtoMessage 

func (*ReplicationResponseEntry) ProtoMessage()

func (*ReplicationResponseEntry) ProtoReflect 

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

func (*ReplicationResponseEntry) Reset 

func (x *ReplicationResponseEntry) Reset()

func (*ReplicationResponseEntry) String 

func (x *ReplicationResponseEntry) String() string

type UnpublishRecordRequest 

type UnpublishRecordRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*UnpublishRecordRequest) Descriptor deprecated 

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

Deprecated: Use UnpublishRecordRequest.ProtoReflect.Descriptor instead.

func (*UnpublishRecordRequest) GetKey 

func (x *UnpublishRecordRequest) GetKey() []byte

func (*UnpublishRecordRequest) ProtoMessage 

func (*UnpublishRecordRequest) ProtoMessage()

func (*UnpublishRecordRequest) ProtoReflect 

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

func (*UnpublishRecordRequest) Reset 

func (x *UnpublishRecordRequest) Reset()

func (*UnpublishRecordRequest) String 

func (x *UnpublishRecordRequest) String() string

type UnpublishRecordResponse 

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

func (*UnpublishRecordResponse) Descriptor deprecated 

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

Deprecated: Use UnpublishRecordResponse.ProtoReflect.Descriptor instead.

func (*UnpublishRecordResponse) ProtoMessage 

func (*UnpublishRecordResponse) ProtoMessage()

func (*UnpublishRecordResponse) ProtoReflect 

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

func (*UnpublishRecordResponse) Reset 

func (x *UnpublishRecordResponse) Reset()

func (*UnpublishRecordResponse) String 

func (x *UnpublishRecordResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.