pb

package
v1.43.0 Latest Latest
Warning

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

Go to latest
Published: Dec 7, 2022 License: AGPL-3.0 Imports: 10 Imported by: 0

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 added in v1.31.0

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

func DRPCRegisterReplicationService

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

func Equal added in v1.29.0

func Equal(x, y proto.Message) bool

Equal is an alias for proto.Equal.

func Marshal added in v1.29.0

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

Marshal is an alias for proto.Marshal.

func Unmarshal added in v1.29.0

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

Unmarshal is an alias for proto.Unmarshal.

Types

type DRPCAdminServiceClient added in v1.31.0

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 added in v1.31.0

func NewDRPCAdminServiceClient(cc drpc.Conn) DRPCAdminServiceClient

type DRPCAdminServiceDescription added in v1.31.0

type DRPCAdminServiceDescription struct{}

func (DRPCAdminServiceDescription) Method added in v1.31.0

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

func (DRPCAdminServiceDescription) NumMethods added in v1.31.0

func (DRPCAdminServiceDescription) NumMethods() int

type DRPCAdminServiceServer added in v1.31.0

type DRPCAdminServiceUnimplementedServer added in v1.31.0

type DRPCAdminServiceUnimplementedServer struct{}

func (*DRPCAdminServiceUnimplementedServer) DeleteRecord added in v1.31.0

func (*DRPCAdminServiceUnimplementedServer) InvalidateRecord added in v1.31.0

func (*DRPCAdminServiceUnimplementedServer) UnpublishRecord added in v1.31.0

type DRPCAdminService_DeleteRecordStream added in v1.31.0

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

type DRPCAdminService_InvalidateRecordStream added in v1.31.0

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

type DRPCAdminService_UnpublishRecordStream added in v1.31.0

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) NumMethods

type DRPCReplicationServiceUnimplementedServer

type DRPCReplicationServiceUnimplementedServer struct{}

func (*DRPCReplicationServiceUnimplementedServer) Peek added in v1.36.0

func (*DRPCReplicationServiceUnimplementedServer) Ping added in v1.28.0

func (*DRPCReplicationServiceUnimplementedServer) Replicate

type DRPCReplicationService_PeekStream added in v1.36.0

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

type DRPCReplicationService_PingStream added in v1.28.0

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

type DRPCReplicationService_ReplicateStream

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

type DeleteRecordRequest added in v1.31.0

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

func (*DeleteRecordRequest) Descriptor deprecated added in v1.31.0

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

Deprecated: Use DeleteRecordRequest.ProtoReflect.Descriptor instead.

func (*DeleteRecordRequest) GetKey added in v1.31.0

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

func (*DeleteRecordRequest) ProtoMessage added in v1.31.0

func (*DeleteRecordRequest) ProtoMessage()

func (*DeleteRecordRequest) ProtoReflect added in v1.31.0

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

func (*DeleteRecordRequest) Reset added in v1.31.0

func (x *DeleteRecordRequest) Reset()

func (*DeleteRecordRequest) String added in v1.31.0

func (x *DeleteRecordRequest) String() string

type DeleteRecordResponse added in v1.31.0

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

func (*DeleteRecordResponse) Descriptor deprecated added in v1.31.0

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

Deprecated: Use DeleteRecordResponse.ProtoReflect.Descriptor instead.

func (*DeleteRecordResponse) ProtoMessage added in v1.31.0

func (*DeleteRecordResponse) ProtoMessage()

func (*DeleteRecordResponse) ProtoReflect added in v1.31.0

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

func (*DeleteRecordResponse) Reset added in v1.31.0

func (x *DeleteRecordResponse) Reset()

func (*DeleteRecordResponse) String added in v1.31.0

func (x *DeleteRecordResponse) String() string

type InvalidateRecordRequest added in v1.31.0

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 added in v1.31.0

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

Deprecated: Use InvalidateRecordRequest.ProtoReflect.Descriptor instead.

func (*InvalidateRecordRequest) GetKey added in v1.31.0

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

func (*InvalidateRecordRequest) GetReason added in v1.31.0

func (x *InvalidateRecordRequest) GetReason() string

func (*InvalidateRecordRequest) ProtoMessage added in v1.31.0

func (*InvalidateRecordRequest) ProtoMessage()

func (*InvalidateRecordRequest) ProtoReflect added in v1.31.0

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

func (*InvalidateRecordRequest) Reset added in v1.31.0

func (x *InvalidateRecordRequest) Reset()

func (*InvalidateRecordRequest) String added in v1.31.0

func (x *InvalidateRecordRequest) String() string

type InvalidateRecordResponse added in v1.31.0

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

func (*InvalidateRecordResponse) Descriptor deprecated added in v1.31.0

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

Deprecated: Use InvalidateRecordResponse.ProtoReflect.Descriptor instead.

func (*InvalidateRecordResponse) ProtoMessage added in v1.31.0

func (*InvalidateRecordResponse) ProtoMessage()

func (*InvalidateRecordResponse) ProtoReflect added in v1.31.0

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

func (*InvalidateRecordResponse) Reset added in v1.31.0

func (x *InvalidateRecordResponse) Reset()

func (*InvalidateRecordResponse) String added in v1.31.0

func (x *InvalidateRecordResponse) String() string

type PeekRequest added in v1.36.0

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 added in v1.36.0

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

Deprecated: Use PeekRequest.ProtoReflect.Descriptor instead.

func (*PeekRequest) GetEncryptionKeyHash added in v1.36.0

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

func (*PeekRequest) ProtoMessage added in v1.36.0

func (*PeekRequest) ProtoMessage()

func (*PeekRequest) ProtoReflect added in v1.36.0

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

func (*PeekRequest) Reset added in v1.36.0

func (x *PeekRequest) Reset()

func (*PeekRequest) String added in v1.36.0

func (x *PeekRequest) String() string

type PeekResponse added in v1.36.0

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

func (*PeekResponse) Descriptor deprecated added in v1.36.0

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

Deprecated: Use PeekResponse.ProtoReflect.Descriptor instead.

func (*PeekResponse) GetRecord added in v1.36.0

func (x *PeekResponse) GetRecord() *Record

func (*PeekResponse) ProtoMessage added in v1.36.0

func (*PeekResponse) ProtoMessage()

func (*PeekResponse) ProtoReflect added in v1.36.0

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

func (*PeekResponse) Reset added in v1.36.0

func (x *PeekResponse) Reset()

func (*PeekResponse) String added in v1.36.0

func (x *PeekResponse) String() string

type PingRequest added in v1.28.0

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

func (*PingRequest) Descriptor deprecated added in v1.28.0

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage added in v1.28.0

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect added in v1.28.0

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

func (*PingRequest) Reset added in v1.28.0

func (x *PingRequest) Reset()

func (*PingRequest) String added in v1.28.0

func (x *PingRequest) String() string

type PingResponse added in v1.28.0

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 added in v1.28.0

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetNodeId added in v1.28.0

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

func (*PingResponse) ProtoMessage added in v1.28.0

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect added in v1.28.0

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

func (*PingResponse) Reset added in v1.28.0

func (x *PingResponse) Reset()

func (*PingResponse) String added in v1.28.0

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) 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 (Record_State) String

func (x Record_State) String() string

func (Record_State) Type

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 added in v1.27.0

func (x *ReplicationRequestEntry) GetClock() uint64

func (*ReplicationRequestEntry) GetNodeId added in v1.27.0

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 added in v1.27.0

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 added in v1.31.0

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

func (*UnpublishRecordRequest) Descriptor deprecated added in v1.31.0

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

Deprecated: Use UnpublishRecordRequest.ProtoReflect.Descriptor instead.

func (*UnpublishRecordRequest) GetKey added in v1.31.0

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

func (*UnpublishRecordRequest) ProtoMessage added in v1.31.0

func (*UnpublishRecordRequest) ProtoMessage()

func (*UnpublishRecordRequest) ProtoReflect added in v1.31.0

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

func (*UnpublishRecordRequest) Reset added in v1.31.0

func (x *UnpublishRecordRequest) Reset()

func (*UnpublishRecordRequest) String added in v1.31.0

func (x *UnpublishRecordRequest) String() string

type UnpublishRecordResponse added in v1.31.0

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

func (*UnpublishRecordResponse) Descriptor deprecated added in v1.31.0

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

Deprecated: Use UnpublishRecordResponse.ProtoReflect.Descriptor instead.

func (*UnpublishRecordResponse) ProtoMessage added in v1.31.0

func (*UnpublishRecordResponse) ProtoMessage()

func (*UnpublishRecordResponse) ProtoReflect added in v1.31.0

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

func (*UnpublishRecordResponse) Reset added in v1.31.0

func (x *UnpublishRecordResponse) Reset()

func (*UnpublishRecordResponse) String added in v1.31.0

func (x *UnpublishRecordResponse) String() string

Jump to

Keyboard shortcuts

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