identityrepoproto

package
v0.3.20 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2024 License: MIT Imports: 11 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

This section is empty.

Variables ¶

View Source 
var (
	ErrInvalidLengthIdentityrepo        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIdentityrepo          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIdentityrepo = fmt.Errorf("proto: unexpected end of group")
)

Functions ¶

func DRPCRegisterIdentityRepo ¶ 

func DRPCRegisterIdentityRepo(mux drpc.Mux, impl DRPCIdentityRepoServer) error

Types ¶

type DRPCIdentityRepoClient ¶ 

type DRPCIdentityRepoClient interface {
	DRPCConn() drpc.Conn

	DataPut(ctx context.Context, in *DataPutRequest) (*Ok, error)
	DataDelete(ctx context.Context, in *DataDeleteRequest) (*Ok, error)
	DataPull(ctx context.Context, in *DataPullRequest) (*DataPullResponse, error)
}

func NewDRPCIdentityRepoClient ¶ 

func NewDRPCIdentityRepoClient(cc drpc.Conn) DRPCIdentityRepoClient

type DRPCIdentityRepoDescription ¶ 

type DRPCIdentityRepoDescription struct{}

func (DRPCIdentityRepoDescription) Method ¶ 

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

func (DRPCIdentityRepoDescription) NumMethods ¶ 

func (DRPCIdentityRepoDescription) NumMethods() int

type DRPCIdentityRepoServer ¶ 

type DRPCIdentityRepoServer interface {
	DataPut(context.Context, *DataPutRequest) (*Ok, error)
	DataDelete(context.Context, *DataDeleteRequest) (*Ok, error)
	DataPull(context.Context, *DataPullRequest) (*DataPullResponse, error)
}

type DRPCIdentityRepoUnimplementedServer ¶ 

type DRPCIdentityRepoUnimplementedServer struct{}

func (*DRPCIdentityRepoUnimplementedServer) DataDelete ¶ 

func (s *DRPCIdentityRepoUnimplementedServer) DataDelete(context.Context, *DataDeleteRequest) (*Ok, error)

func (*DRPCIdentityRepoUnimplementedServer) DataPull ¶ 

func (s *DRPCIdentityRepoUnimplementedServer) DataPull(context.Context, *DataPullRequest) (*DataPullResponse, error)

func (*DRPCIdentityRepoUnimplementedServer) DataPut ¶ 

func (s *DRPCIdentityRepoUnimplementedServer) DataPut(context.Context, *DataPutRequest) (*Ok, error)

type DRPCIdentityRepo_DataDeleteStream ¶ 

type DRPCIdentityRepo_DataDeleteStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCIdentityRepo_DataPullStream ¶ 

type DRPCIdentityRepo_DataPullStream interface {
	drpc.Stream
	SendAndClose(*DataPullResponse) error
}

type DRPCIdentityRepo_DataPutStream ¶ 

type DRPCIdentityRepo_DataPutStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type Data ¶ 

type Data struct {
	// kind is a string representing the kind of data
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// data is a byte payload
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// data signature
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*Data) Descriptor ¶ 

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

func (*Data) GetData ¶ 

func (m *Data) GetData() []byte

func (*Data) GetKind ¶ 

func (m *Data) GetKind() string

func (*Data) GetSignature ¶ 

func (m *Data) GetSignature() []byte

func (*Data) Marshal ¶ 

func (m *Data) Marshal() (dAtA []byte, err error)

func (*Data) MarshalTo ¶ 

func (m *Data) MarshalTo(dAtA []byte) (int, error)

func (*Data) MarshalToSizedBuffer ¶ 

func (m *Data) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Data) ProtoMessage ¶ 

func (*Data) ProtoMessage()

func (*Data) Reset ¶ 

func (m *Data) Reset()

func (*Data) Size ¶ 

func (m *Data) Size() (n int)

func (*Data) String ¶ 

func (m *Data) String() string

func (*Data) Unmarshal ¶ 

func (m *Data) Unmarshal(dAtA []byte) error

func (*Data) XXX_DiscardUnknown ¶ 

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal ¶ 

func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Data) XXX_Merge ¶ 

func (m *Data) XXX_Merge(src proto.Message)

func (*Data) XXX_Size ¶ 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal ¶ 

func (m *Data) XXX_Unmarshal(b []byte) error

type DataDeleteRequest ¶ 

type DataDeleteRequest struct {
	// string representation of identity, must be equal handshake result
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// kinds of data to delete, if empty all kinds will be deleted
	Kinds []string `protobuf:"bytes,2,rep,name=kinds,proto3" json:"kinds,omitempty"`
}

func (*DataDeleteRequest) Descriptor ¶ 

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

func (*DataDeleteRequest) GetIdentity ¶ 

func (m *DataDeleteRequest) GetIdentity() string

func (*DataDeleteRequest) GetKinds ¶ 

func (m *DataDeleteRequest) GetKinds() []string

func (*DataDeleteRequest) Marshal ¶ 

func (m *DataDeleteRequest) Marshal() (dAtA []byte, err error)

func (*DataDeleteRequest) MarshalTo ¶ 

func (m *DataDeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*DataDeleteRequest) MarshalToSizedBuffer ¶ 

func (m *DataDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataDeleteRequest) ProtoMessage ¶ 

func (*DataDeleteRequest) ProtoMessage()

func (*DataDeleteRequest) Reset ¶ 

func (m *DataDeleteRequest) Reset()

func (*DataDeleteRequest) Size ¶ 

func (m *DataDeleteRequest) Size() (n int)

func (*DataDeleteRequest) String ¶ 

func (m *DataDeleteRequest) String() string

func (*DataDeleteRequest) Unmarshal ¶ 

func (m *DataDeleteRequest) Unmarshal(dAtA []byte) error

func (*DataDeleteRequest) XXX_DiscardUnknown ¶ 

func (m *DataDeleteRequest) XXX_DiscardUnknown()

func (*DataDeleteRequest) XXX_Marshal ¶ 

func (m *DataDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataDeleteRequest) XXX_Merge ¶ 

func (m *DataDeleteRequest) XXX_Merge(src proto.Message)

func (*DataDeleteRequest) XXX_Size ¶ 

func (m *DataDeleteRequest) XXX_Size() int

func (*DataDeleteRequest) XXX_Unmarshal ¶ 

func (m *DataDeleteRequest) XXX_Unmarshal(b []byte) error

type DataPullRequest ¶ 

type DataPullRequest struct {
	// list of identities wanted to request
	Identities []string `protobuf:"bytes,1,rep,name=identities,proto3" json:"identities,omitempty"`
	// kinds of data wanted to request
	Kinds []string `protobuf:"bytes,2,rep,name=kinds,proto3" json:"kinds,omitempty"`
}

func (*DataPullRequest) Descriptor ¶ 

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

func (*DataPullRequest) GetIdentities ¶ 

func (m *DataPullRequest) GetIdentities() []string

func (*DataPullRequest) GetKinds ¶ 

func (m *DataPullRequest) GetKinds() []string

func (*DataPullRequest) Marshal ¶ 

func (m *DataPullRequest) Marshal() (dAtA []byte, err error)

func (*DataPullRequest) MarshalTo ¶ 

func (m *DataPullRequest) MarshalTo(dAtA []byte) (int, error)

func (*DataPullRequest) MarshalToSizedBuffer ¶ 

func (m *DataPullRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataPullRequest) ProtoMessage ¶ 

func (*DataPullRequest) ProtoMessage()

func (*DataPullRequest) Reset ¶ 

func (m *DataPullRequest) Reset()

func (*DataPullRequest) Size ¶ 

func (m *DataPullRequest) Size() (n int)

func (*DataPullRequest) String ¶ 

func (m *DataPullRequest) String() string

func (*DataPullRequest) Unmarshal ¶ 

func (m *DataPullRequest) Unmarshal(dAtA []byte) error

func (*DataPullRequest) XXX_DiscardUnknown ¶ 

func (m *DataPullRequest) XXX_DiscardUnknown()

func (*DataPullRequest) XXX_Marshal ¶ 

func (m *DataPullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataPullRequest) XXX_Merge ¶ 

func (m *DataPullRequest) XXX_Merge(src proto.Message)

func (*DataPullRequest) XXX_Size ¶ 

func (m *DataPullRequest) XXX_Size() int

func (*DataPullRequest) XXX_Unmarshal ¶ 

func (m *DataPullRequest) XXX_Unmarshal(b []byte) error

type DataPullResponse ¶ 

type DataPullResponse struct {
	Data []*DataWithIdentity `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
}

func (*DataPullResponse) Descriptor ¶ 

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

func (*DataPullResponse) GetData ¶ 

func (m *DataPullResponse) GetData() []*DataWithIdentity

func (*DataPullResponse) Marshal ¶ 

func (m *DataPullResponse) Marshal() (dAtA []byte, err error)

func (*DataPullResponse) MarshalTo ¶ 

func (m *DataPullResponse) MarshalTo(dAtA []byte) (int, error)

func (*DataPullResponse) MarshalToSizedBuffer ¶ 

func (m *DataPullResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataPullResponse) ProtoMessage ¶ 

func (*DataPullResponse) ProtoMessage()

func (*DataPullResponse) Reset ¶ 

func (m *DataPullResponse) Reset()

func (*DataPullResponse) Size ¶ 

func (m *DataPullResponse) Size() (n int)

func (*DataPullResponse) String ¶ 

func (m *DataPullResponse) String() string

func (*DataPullResponse) Unmarshal ¶ 

func (m *DataPullResponse) Unmarshal(dAtA []byte) error

func (*DataPullResponse) XXX_DiscardUnknown ¶ 

func (m *DataPullResponse) XXX_DiscardUnknown()

func (*DataPullResponse) XXX_Marshal ¶ 

func (m *DataPullResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataPullResponse) XXX_Merge ¶ 

func (m *DataPullResponse) XXX_Merge(src proto.Message)

func (*DataPullResponse) XXX_Size ¶ 

func (m *DataPullResponse) XXX_Size() int

func (*DataPullResponse) XXX_Unmarshal ¶ 

func (m *DataPullResponse) XXX_Unmarshal(b []byte) error

type DataPutRequest ¶ 

type DataPutRequest struct {
	// string representation of identity, must be equal handshake result
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// data to save
	Data []*Data `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
}

func (*DataPutRequest) Descriptor ¶ 

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

func (*DataPutRequest) GetData ¶ 

func (m *DataPutRequest) GetData() []*Data

func (*DataPutRequest) GetIdentity ¶ 

func (m *DataPutRequest) GetIdentity() string

func (*DataPutRequest) Marshal ¶ 

func (m *DataPutRequest) Marshal() (dAtA []byte, err error)

func (*DataPutRequest) MarshalTo ¶ 

func (m *DataPutRequest) MarshalTo(dAtA []byte) (int, error)

func (*DataPutRequest) MarshalToSizedBuffer ¶ 

func (m *DataPutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataPutRequest) ProtoMessage ¶ 

func (*DataPutRequest) ProtoMessage()

func (*DataPutRequest) Reset ¶ 

func (m *DataPutRequest) Reset()

func (*DataPutRequest) Size ¶ 

func (m *DataPutRequest) Size() (n int)

func (*DataPutRequest) String ¶ 

func (m *DataPutRequest) String() string

func (*DataPutRequest) Unmarshal ¶ 

func (m *DataPutRequest) Unmarshal(dAtA []byte) error

func (*DataPutRequest) XXX_DiscardUnknown ¶ 

func (m *DataPutRequest) XXX_DiscardUnknown()

func (*DataPutRequest) XXX_Marshal ¶ 

func (m *DataPutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataPutRequest) XXX_Merge ¶ 

func (m *DataPutRequest) XXX_Merge(src proto.Message)

func (*DataPutRequest) XXX_Size ¶ 

func (m *DataPutRequest) XXX_Size() int

func (*DataPutRequest) XXX_Unmarshal ¶ 

func (m *DataPutRequest) XXX_Unmarshal(b []byte) error

type DataWithIdentity ¶ 

type DataWithIdentity struct {
	Identity string  `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Data     []*Data `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
}

func (*DataWithIdentity) Descriptor ¶ 

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

func (*DataWithIdentity) GetData ¶ 

func (m *DataWithIdentity) GetData() []*Data

func (*DataWithIdentity) GetIdentity ¶ 

func (m *DataWithIdentity) GetIdentity() string

func (*DataWithIdentity) Marshal ¶ 

func (m *DataWithIdentity) Marshal() (dAtA []byte, err error)

func (*DataWithIdentity) MarshalTo ¶ 

func (m *DataWithIdentity) MarshalTo(dAtA []byte) (int, error)

func (*DataWithIdentity) MarshalToSizedBuffer ¶ 

func (m *DataWithIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataWithIdentity) ProtoMessage ¶ 

func (*DataWithIdentity) ProtoMessage()

func (*DataWithIdentity) Reset ¶ 

func (m *DataWithIdentity) Reset()

func (*DataWithIdentity) Size ¶ 

func (m *DataWithIdentity) Size() (n int)

func (*DataWithIdentity) String ¶ 

func (m *DataWithIdentity) String() string

func (*DataWithIdentity) Unmarshal ¶ 

func (m *DataWithIdentity) Unmarshal(dAtA []byte) error

func (*DataWithIdentity) XXX_DiscardUnknown ¶ 

func (m *DataWithIdentity) XXX_DiscardUnknown()

func (*DataWithIdentity) XXX_Marshal ¶ 

func (m *DataWithIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataWithIdentity) XXX_Merge ¶ 

func (m *DataWithIdentity) XXX_Merge(src proto.Message)

func (*DataWithIdentity) XXX_Size ¶ 

func (m *DataWithIdentity) XXX_Size() int

func (*DataWithIdentity) XXX_Unmarshal ¶ 

func (m *DataWithIdentity) XXX_Unmarshal(b []byte) error

type Ok ¶ 

type Ok struct {
}

func (*Ok) Descriptor ¶ 

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

func (*Ok) Marshal ¶ 

func (m *Ok) Marshal() (dAtA []byte, err error)

func (*Ok) MarshalTo ¶ 

func (m *Ok) MarshalTo(dAtA []byte) (int, error)

func (*Ok) MarshalToSizedBuffer ¶ 

func (m *Ok) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ok) ProtoMessage ¶ 

func (*Ok) ProtoMessage()

func (*Ok) Reset ¶ 

func (m *Ok) Reset()

func (*Ok) Size ¶ 

func (m *Ok) Size() (n int)

func (*Ok) String ¶ 

func (m *Ok) String() string

func (*Ok) Unmarshal ¶ 

func (m *Ok) Unmarshal(dAtA []byte) error

func (*Ok) XXX_DiscardUnknown ¶ 

func (m *Ok) XXX_DiscardUnknown()

func (*Ok) XXX_Marshal ¶ 

func (m *Ok) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ok) XXX_Merge ¶ 

func (m *Ok) XXX_Merge(src proto.Message)

func (*Ok) XXX_Size ¶ 

func (m *Ok) XXX_Size() int

func (*Ok) XXX_Unmarshal ¶ 

func (m *Ok) XXX_Unmarshal(b []byte) 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.