subjectv1

package
v0.0.0-...-324de33 Latest Latest
Warning

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

 Go to latest Published: Sep 6, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Index

Constants

View Source 
const (
	Msg_CreateSubject_FullMethodName         = "/chora.subject.v1.Msg/CreateSubject"
	Msg_RemoveSubject_FullMethodName         = "/chora.subject.v1.Msg/RemoveSubject"
	Msg_UpdateSubjectSteward_FullMethodName  = "/chora.subject.v1.Msg/UpdateSubjectSteward"
	Msg_UpdateSubjectMetadata_FullMethodName = "/chora.subject.v1.Msg/UpdateSubjectMetadata"
)
View Source 
const (
	Query_Subject_FullMethodName           = "/chora.subject.v1.Query/Subject"
	Query_Subjects_FullMethodName          = "/chora.subject.v1.Query/Subjects"
	Query_SubjectsBySteward_FullMethodName = "/chora.subject.v1.Query/SubjectsBySteward"
)

Variables

View Source 
var File_chora_subject_v1_doc_proto protoreflect.FileDescriptor
View Source 
var File_chora_subject_v1_events_proto protoreflect.FileDescriptor
View Source 
var File_chora_subject_v1_msg_proto protoreflect.FileDescriptor
View Source 
var File_chora_subject_v1_query_proto protoreflect.FileDescriptor
View Source 
var File_chora_subject_v1_state_proto protoreflect.FileDescriptor
View Source 
var Msg_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chora.subject.v1.Msg",
	HandlerType: (*MsgServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateSubject",
			Handler:    _Msg_CreateSubject_Handler,
		},
		{
			MethodName: "RemoveSubject",
			Handler:    _Msg_RemoveSubject_Handler,
		},
		{
			MethodName: "UpdateSubjectSteward",
			Handler:    _Msg_UpdateSubjectSteward_Handler,
		},
		{
			MethodName: "UpdateSubjectMetadata",
			Handler:    _Msg_UpdateSubjectMetadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chora/subject/v1/msg.proto",
}

Msg_ServiceDesc is the grpc.ServiceDesc for Msg 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 Query_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chora.subject.v1.Query",
	HandlerType: (*QueryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Subject",
			Handler:    _Query_Subject_Handler,
		},
		{
			MethodName: "Subjects",
			Handler:    _Query_Subjects_Handler,
		},
		{
			MethodName: "SubjectsBySteward",
			Handler:    _Query_SubjectsBySteward_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chora/subject/v1/query.proto",
}

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

Functions

func RegisterMsgServer 

func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)

func RegisterQueryServer 

func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)

Types

type EventCreateSubject 

type EventCreateSubject struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

EventCreateSubject is an event emitted when an subject is created.

func (*EventCreateSubject) Descriptor deprecated 

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

Deprecated: Use EventCreateSubject.ProtoReflect.Descriptor instead.

func (*EventCreateSubject) GetAddress 

func (x *EventCreateSubject) GetAddress() string

func (*EventCreateSubject) ProtoMessage 

func (*EventCreateSubject) ProtoMessage()

func (*EventCreateSubject) ProtoReflect 

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

func (*EventCreateSubject) Reset 

func (x *EventCreateSubject) Reset()

func (*EventCreateSubject) String 

func (x *EventCreateSubject) String() string

type EventRemoveSubject 

type EventRemoveSubject struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

EventRemoveSubject is an event emitted when an subject is removed.

func (*EventRemoveSubject) Descriptor deprecated 

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

Deprecated: Use EventRemoveSubject.ProtoReflect.Descriptor instead.

func (*EventRemoveSubject) GetAddress 

func (x *EventRemoveSubject) GetAddress() string

func (*EventRemoveSubject) ProtoMessage 

func (*EventRemoveSubject) ProtoMessage()

func (*EventRemoveSubject) ProtoReflect 

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

func (*EventRemoveSubject) Reset 

func (x *EventRemoveSubject) Reset()

func (*EventRemoveSubject) String 

func (x *EventRemoveSubject) String() string

type EventUpdateSubjectMetadata 

type EventUpdateSubjectMetadata struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

EventUpdateSubjectMetadata is an event emitted when the subject metadata is updated.

func (*EventUpdateSubjectMetadata) Descriptor deprecated 

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

Deprecated: Use EventUpdateSubjectMetadata.ProtoReflect.Descriptor instead.

func (*EventUpdateSubjectMetadata) GetAddress 

func (x *EventUpdateSubjectMetadata) GetAddress() string

func (*EventUpdateSubjectMetadata) ProtoMessage 

func (*EventUpdateSubjectMetadata) ProtoMessage()

func (*EventUpdateSubjectMetadata) ProtoReflect 

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

func (*EventUpdateSubjectMetadata) Reset 

func (x *EventUpdateSubjectMetadata) Reset()

func (*EventUpdateSubjectMetadata) String 

func (x *EventUpdateSubjectMetadata) String() string

type EventUpdateSubjectSteward 

type EventUpdateSubjectSteward struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

EventUpdateSubjectSteward is an event emitted when the subject steward is updated.

func (*EventUpdateSubjectSteward) Descriptor deprecated 

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

Deprecated: Use EventUpdateSubjectSteward.ProtoReflect.Descriptor instead.

func (*EventUpdateSubjectSteward) GetAddress 

func (x *EventUpdateSubjectSteward) GetAddress() string

func (*EventUpdateSubjectSteward) ProtoMessage 

func (*EventUpdateSubjectSteward) ProtoMessage()

func (*EventUpdateSubjectSteward) ProtoReflect 

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

func (*EventUpdateSubjectSteward) Reset 

func (x *EventUpdateSubjectSteward) Reset()

func (*EventUpdateSubjectSteward) String 

func (x *EventUpdateSubjectSteward) String() string

type MsgClient 

type MsgClient interface {
	// CreateSubject creates an subject.
	CreateSubject(ctx context.Context, in *MsgCreateSubject, opts ...grpc.CallOption) (*MsgCreateSubjectResponse, error)
	// RemoveSubject removes an subject.
	RemoveSubject(ctx context.Context, in *MsgRemoveSubject, opts ...grpc.CallOption) (*MsgRemoveSubjectResponse, error)
	// UpdateSubjectSteward updates the subject steward.
	UpdateSubjectSteward(ctx context.Context, in *MsgUpdateSubjectSteward, opts ...grpc.CallOption) (*MsgUpdateSubjectStewardResponse, error)
	// UpdateSubjectMetadata updates the subject metadata.
	UpdateSubjectMetadata(ctx context.Context, in *MsgUpdateSubjectMetadata, opts ...grpc.CallOption) (*MsgUpdateSubjectMetadataResponse, error)
}

MsgClient is the client API for Msg 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.

Msg is the Msg service.

func NewMsgClient 

func NewMsgClient(cc grpc.ClientConnInterface) MsgClient

type MsgCreateSubject 

type MsgCreateSubject struct {

	// steward is the address of the subject steward.
	Steward string `protobuf:"bytes,1,opt,name=steward,proto3" json:"steward,omitempty"`
	// metadata is the metadata of the subject.
	Metadata string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

MsgCreateSubject is the Msg/CreateSubject request type.

func (*MsgCreateSubject) Descriptor deprecated 

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

Deprecated: Use MsgCreateSubject.ProtoReflect.Descriptor instead.

func (*MsgCreateSubject) GetMetadata 

func (x *MsgCreateSubject) GetMetadata() string

func (*MsgCreateSubject) GetSteward 

func (x *MsgCreateSubject) GetSteward() string

func (*MsgCreateSubject) ProtoMessage 

func (*MsgCreateSubject) ProtoMessage()

func (*MsgCreateSubject) ProtoReflect 

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

func (*MsgCreateSubject) Reset 

func (x *MsgCreateSubject) Reset()

func (*MsgCreateSubject) String 

func (x *MsgCreateSubject) String() string

type MsgCreateSubjectResponse 

type MsgCreateSubjectResponse struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

MsgCreateSubjectResponse is the Msg/CreateSubject response type.

func (*MsgCreateSubjectResponse) Descriptor deprecated 

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

Deprecated: Use MsgCreateSubjectResponse.ProtoReflect.Descriptor instead.

func (*MsgCreateSubjectResponse) GetAddress 

func (x *MsgCreateSubjectResponse) GetAddress() string

func (*MsgCreateSubjectResponse) ProtoMessage 

func (*MsgCreateSubjectResponse) ProtoMessage()

func (*MsgCreateSubjectResponse) ProtoReflect 

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

func (*MsgCreateSubjectResponse) Reset 

func (x *MsgCreateSubjectResponse) Reset()

func (*MsgCreateSubjectResponse) String 

func (x *MsgCreateSubjectResponse) String() string

type MsgRemoveSubject 

type MsgRemoveSubject struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// steward is the address of the subject steward.
	Steward string `protobuf:"bytes,2,opt,name=steward,proto3" json:"steward,omitempty"`
	// contains filtered or unexported fields
}

MsgRemoveSubject is the Msg/RemoveSubject request type.

func (*MsgRemoveSubject) Descriptor deprecated 

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

Deprecated: Use MsgRemoveSubject.ProtoReflect.Descriptor instead.

func (*MsgRemoveSubject) GetAddress 

func (x *MsgRemoveSubject) GetAddress() string

func (*MsgRemoveSubject) GetSteward 

func (x *MsgRemoveSubject) GetSteward() string

func (*MsgRemoveSubject) ProtoMessage 

func (*MsgRemoveSubject) ProtoMessage()

func (*MsgRemoveSubject) ProtoReflect 

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

func (*MsgRemoveSubject) Reset 

func (x *MsgRemoveSubject) Reset()

func (*MsgRemoveSubject) String 

func (x *MsgRemoveSubject) String() string

type MsgRemoveSubjectResponse 

type MsgRemoveSubjectResponse struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

MsgRemoveSubjectResponse is the Msg/RemoveSubject response type.

func (*MsgRemoveSubjectResponse) Descriptor deprecated 

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

Deprecated: Use MsgRemoveSubjectResponse.ProtoReflect.Descriptor instead.

func (*MsgRemoveSubjectResponse) GetAddress 

func (x *MsgRemoveSubjectResponse) GetAddress() string

func (*MsgRemoveSubjectResponse) ProtoMessage 

func (*MsgRemoveSubjectResponse) ProtoMessage()

func (*MsgRemoveSubjectResponse) ProtoReflect 

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

func (*MsgRemoveSubjectResponse) Reset 

func (x *MsgRemoveSubjectResponse) Reset()

func (*MsgRemoveSubjectResponse) String 

func (x *MsgRemoveSubjectResponse) String() string

type MsgServer 

type MsgServer interface {
	// CreateSubject creates an subject.
	CreateSubject(context.Context, *MsgCreateSubject) (*MsgCreateSubjectResponse, error)
	// RemoveSubject removes an subject.
	RemoveSubject(context.Context, *MsgRemoveSubject) (*MsgRemoveSubjectResponse, error)
	// UpdateSubjectSteward updates the subject steward.
	UpdateSubjectSteward(context.Context, *MsgUpdateSubjectSteward) (*MsgUpdateSubjectStewardResponse, error)
	// UpdateSubjectMetadata updates the subject metadata.
	UpdateSubjectMetadata(context.Context, *MsgUpdateSubjectMetadata) (*MsgUpdateSubjectMetadataResponse, error)
	// contains filtered or unexported methods
}

MsgServer is the server API for Msg service. All implementations must embed UnimplementedMsgServer for forward compatibility.

Msg is the Msg service.

type MsgUpdateSubjectMetadata 

type MsgUpdateSubjectMetadata struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// steward is the address of the subject steward.
	Steward string `protobuf:"bytes,2,opt,name=steward,proto3" json:"steward,omitempty"`
	// new_metadata is the new metadata of the subject.
	NewMetadata string `protobuf:"bytes,3,opt,name=new_metadata,json=newMetadata,proto3" json:"new_metadata,omitempty"`
	// contains filtered or unexported fields
}

MsgUpdateSubjectMetadata is the Msg/UpdateSubjectMetadata request type.

func (*MsgUpdateSubjectMetadata) Descriptor deprecated 

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

Deprecated: Use MsgUpdateSubjectMetadata.ProtoReflect.Descriptor instead.

func (*MsgUpdateSubjectMetadata) GetAddress 

func (x *MsgUpdateSubjectMetadata) GetAddress() string

func (*MsgUpdateSubjectMetadata) GetNewMetadata 

func (x *MsgUpdateSubjectMetadata) GetNewMetadata() string

func (*MsgUpdateSubjectMetadata) GetSteward 

func (x *MsgUpdateSubjectMetadata) GetSteward() string

func (*MsgUpdateSubjectMetadata) ProtoMessage 

func (*MsgUpdateSubjectMetadata) ProtoMessage()

func (*MsgUpdateSubjectMetadata) ProtoReflect 

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

func (*MsgUpdateSubjectMetadata) Reset 

func (x *MsgUpdateSubjectMetadata) Reset()

func (*MsgUpdateSubjectMetadata) String 

func (x *MsgUpdateSubjectMetadata) String() string

type MsgUpdateSubjectMetadataResponse 

type MsgUpdateSubjectMetadataResponse struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

MsgUpdateSubjectMetadataResponse is the Msg/UpdateSubjectMetadata response type.

func (*MsgUpdateSubjectMetadataResponse) Descriptor deprecated 

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

Deprecated: Use MsgUpdateSubjectMetadataResponse.ProtoReflect.Descriptor instead.

func (*MsgUpdateSubjectMetadataResponse) GetAddress 

func (x *MsgUpdateSubjectMetadataResponse) GetAddress() string

func (*MsgUpdateSubjectMetadataResponse) ProtoMessage 

func (*MsgUpdateSubjectMetadataResponse) ProtoMessage()

func (*MsgUpdateSubjectMetadataResponse) ProtoReflect 

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

func (*MsgUpdateSubjectMetadataResponse) Reset 

func (x *MsgUpdateSubjectMetadataResponse) Reset()

func (*MsgUpdateSubjectMetadataResponse) String 

func (x *MsgUpdateSubjectMetadataResponse) String() string

type MsgUpdateSubjectSteward 

type MsgUpdateSubjectSteward struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// steward is the address of the subject steward.
	Steward string `protobuf:"bytes,2,opt,name=steward,proto3" json:"steward,omitempty"`
	// new_steward is the address of the new steward.
	NewSteward string `protobuf:"bytes,3,opt,name=new_steward,json=newSteward,proto3" json:"new_steward,omitempty"`
	// contains filtered or unexported fields
}

MsgUpdateSubjectSteward is the Msg/UpdateSubjectSteward request type.

func (*MsgUpdateSubjectSteward) Descriptor deprecated 

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

Deprecated: Use MsgUpdateSubjectSteward.ProtoReflect.Descriptor instead.

func (*MsgUpdateSubjectSteward) GetAddress 

func (x *MsgUpdateSubjectSteward) GetAddress() string

func (*MsgUpdateSubjectSteward) GetNewSteward 

func (x *MsgUpdateSubjectSteward) GetNewSteward() string

func (*MsgUpdateSubjectSteward) GetSteward 

func (x *MsgUpdateSubjectSteward) GetSteward() string

func (*MsgUpdateSubjectSteward) ProtoMessage 

func (*MsgUpdateSubjectSteward) ProtoMessage()

func (*MsgUpdateSubjectSteward) ProtoReflect 

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

func (*MsgUpdateSubjectSteward) Reset 

func (x *MsgUpdateSubjectSteward) Reset()

func (*MsgUpdateSubjectSteward) String 

func (x *MsgUpdateSubjectSteward) String() string

type MsgUpdateSubjectStewardResponse 

type MsgUpdateSubjectStewardResponse struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

MsgUpdateSubjectStewardResponse is the Msg/UpdateSubjectSteward response type.

func (*MsgUpdateSubjectStewardResponse) Descriptor deprecated 

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

Deprecated: Use MsgUpdateSubjectStewardResponse.ProtoReflect.Descriptor instead.

func (*MsgUpdateSubjectStewardResponse) GetAddress 

func (x *MsgUpdateSubjectStewardResponse) GetAddress() string

func (*MsgUpdateSubjectStewardResponse) ProtoMessage 

func (*MsgUpdateSubjectStewardResponse) ProtoMessage()

func (*MsgUpdateSubjectStewardResponse) ProtoReflect 

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

func (*MsgUpdateSubjectStewardResponse) Reset 

func (x *MsgUpdateSubjectStewardResponse) Reset()

func (*MsgUpdateSubjectStewardResponse) String 

func (x *MsgUpdateSubjectStewardResponse) String() string

type QueryClient 

type QueryClient interface {
	// Subject queries an subject by address.
	Subject(ctx context.Context, in *QuerySubjectRequest, opts ...grpc.CallOption) (*QuerySubjectResponse, error)
	// Subjects queries all subjects.
	Subjects(ctx context.Context, in *QuerySubjectsRequest, opts ...grpc.CallOption) (*QuerySubjectsResponse, error)
	// SubjectsBySteward queries subjects by steward.
	SubjectsBySteward(ctx context.Context, in *QuerySubjectsByStewardRequest, opts ...grpc.CallOption) (*QuerySubjectsByStewardResponse, error)
}

QueryClient is the client API for Query 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.

Query is the Query service.

func NewQueryClient 

func NewQueryClient(cc grpc.ClientConnInterface) QueryClient

type QueryServer 

type QueryServer interface {
	// Subject queries an subject by address.
	Subject(context.Context, *QuerySubjectRequest) (*QuerySubjectResponse, error)
	// Subjects queries all subjects.
	Subjects(context.Context, *QuerySubjectsRequest) (*QuerySubjectsResponse, error)
	// SubjectsBySteward queries subjects by steward.
	SubjectsBySteward(context.Context, *QuerySubjectsByStewardRequest) (*QuerySubjectsByStewardResponse, error)
	// contains filtered or unexported methods
}

QueryServer is the server API for Query service. All implementations must embed UnimplementedQueryServer for forward compatibility.

Query is the Query service.

type QuerySubjectRequest 

type QuerySubjectRequest struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

QuerySubjectRequest is the Query/Subject request type.

func (*QuerySubjectRequest) Descriptor deprecated 

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

Deprecated: Use QuerySubjectRequest.ProtoReflect.Descriptor instead.

func (*QuerySubjectRequest) GetAddress 

func (x *QuerySubjectRequest) GetAddress() string

func (*QuerySubjectRequest) ProtoMessage 

func (*QuerySubjectRequest) ProtoMessage()

func (*QuerySubjectRequest) ProtoReflect 

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

func (*QuerySubjectRequest) Reset 

func (x *QuerySubjectRequest) Reset()

func (*QuerySubjectRequest) String 

func (x *QuerySubjectRequest) String() string

type QuerySubjectResponse 

type QuerySubjectResponse struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// steward is the address of the subject steward.
	Steward string `protobuf:"bytes,2,opt,name=steward,proto3" json:"steward,omitempty"`
	// metadata is the metadata of the subject.
	Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

QuerySubjectResponse is the Query/Subject response type.

func (*QuerySubjectResponse) Descriptor deprecated 

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

Deprecated: Use QuerySubjectResponse.ProtoReflect.Descriptor instead.

func (*QuerySubjectResponse) GetAddress 

func (x *QuerySubjectResponse) GetAddress() string

func (*QuerySubjectResponse) GetMetadata 

func (x *QuerySubjectResponse) GetMetadata() string

func (*QuerySubjectResponse) GetSteward 

func (x *QuerySubjectResponse) GetSteward() string

func (*QuerySubjectResponse) ProtoMessage 

func (*QuerySubjectResponse) ProtoMessage()

func (*QuerySubjectResponse) ProtoReflect 

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

func (*QuerySubjectResponse) Reset 

func (x *QuerySubjectResponse) Reset()

func (*QuerySubjectResponse) String 

func (x *QuerySubjectResponse) String() string

type QuerySubjectsByStewardRequest 

type QuerySubjectsByStewardRequest struct {

	// steward is the address of the subject steward.
	Steward string `protobuf:"bytes,1,opt,name=steward,proto3" json:"steward,omitempty"`
	// pagination is the optional pagination of the request.
	Pagination *v1beta1.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QuerySubjectsByStewardRequest is the Query/SubjectsBySteward request type.

func (*QuerySubjectsByStewardRequest) Descriptor deprecated 

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

Deprecated: Use QuerySubjectsByStewardRequest.ProtoReflect.Descriptor instead.

func (*QuerySubjectsByStewardRequest) GetPagination 

func (x *QuerySubjectsByStewardRequest) GetPagination() *v1beta1.PageRequest

func (*QuerySubjectsByStewardRequest) GetSteward 

func (x *QuerySubjectsByStewardRequest) GetSteward() string

func (*QuerySubjectsByStewardRequest) ProtoMessage 

func (*QuerySubjectsByStewardRequest) ProtoMessage()

func (*QuerySubjectsByStewardRequest) ProtoReflect 

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

func (*QuerySubjectsByStewardRequest) Reset 

func (x *QuerySubjectsByStewardRequest) Reset()

func (*QuerySubjectsByStewardRequest) String 

func (x *QuerySubjectsByStewardRequest) String() string

type QuerySubjectsByStewardResponse 

type QuerySubjectsByStewardResponse struct {

	// steward is the address of the subject steward.
	Steward string `protobuf:"bytes,1,opt,name=steward,proto3" json:"steward,omitempty"`
	// subjects is the list of subjects managed by the steward.
	Subjects []*QuerySubjectsByStewardResponse_Subject `protobuf:"bytes,2,rep,name=subjects,proto3" json:"subjects,omitempty"`
	// pagination is the pagination of the response.
	Pagination *v1beta1.PageResponse `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QuerySubjectsByStewardResponse is the Query/SubjectsBySteward response type.

func (*QuerySubjectsByStewardResponse) Descriptor deprecated 

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

Deprecated: Use QuerySubjectsByStewardResponse.ProtoReflect.Descriptor instead.

func (*QuerySubjectsByStewardResponse) GetPagination 

func (x *QuerySubjectsByStewardResponse) GetPagination() *v1beta1.PageResponse

func (*QuerySubjectsByStewardResponse) GetSteward 

func (x *QuerySubjectsByStewardResponse) GetSteward() string

func (*QuerySubjectsByStewardResponse) GetSubjects 

func (x *QuerySubjectsByStewardResponse) GetSubjects() []*QuerySubjectsByStewardResponse_Subject

func (*QuerySubjectsByStewardResponse) ProtoMessage 

func (*QuerySubjectsByStewardResponse) ProtoMessage()

func (*QuerySubjectsByStewardResponse) ProtoReflect 

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

func (*QuerySubjectsByStewardResponse) Reset 

func (x *QuerySubjectsByStewardResponse) Reset()

func (*QuerySubjectsByStewardResponse) String 

func (x *QuerySubjectsByStewardResponse) String() string

type QuerySubjectsByStewardResponse_Subject 

type QuerySubjectsByStewardResponse_Subject struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// metadata is the metadata of the subject.
	Metadata string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Subject is the subject properties.

func (*QuerySubjectsByStewardResponse_Subject) Descriptor deprecated 

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

Deprecated: Use QuerySubjectsByStewardResponse_Subject.ProtoReflect.Descriptor instead.

func (*QuerySubjectsByStewardResponse_Subject) GetAddress 

func (x *QuerySubjectsByStewardResponse_Subject) GetAddress() string

func (*QuerySubjectsByStewardResponse_Subject) GetMetadata 

func (x *QuerySubjectsByStewardResponse_Subject) GetMetadata() string

func (*QuerySubjectsByStewardResponse_Subject) ProtoMessage 

func (*QuerySubjectsByStewardResponse_Subject) ProtoMessage()

func (*QuerySubjectsByStewardResponse_Subject) ProtoReflect 

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

func (*QuerySubjectsByStewardResponse_Subject) Reset 

func (x *QuerySubjectsByStewardResponse_Subject) Reset()

func (*QuerySubjectsByStewardResponse_Subject) String 

func (x *QuerySubjectsByStewardResponse_Subject) String() string

type QuerySubjectsRequest 

type QuerySubjectsRequest struct {

	// pagination is the optional pagination of the request.
	Pagination *v1beta1.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QuerySubjectsRequest is the Query/Subjects request type.

func (*QuerySubjectsRequest) Descriptor deprecated 

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

Deprecated: Use QuerySubjectsRequest.ProtoReflect.Descriptor instead.

func (*QuerySubjectsRequest) GetPagination 

func (x *QuerySubjectsRequest) GetPagination() *v1beta1.PageRequest

func (*QuerySubjectsRequest) ProtoMessage 

func (*QuerySubjectsRequest) ProtoMessage()

func (*QuerySubjectsRequest) ProtoReflect 

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

func (*QuerySubjectsRequest) Reset 

func (x *QuerySubjectsRequest) Reset()

func (*QuerySubjectsRequest) String 

func (x *QuerySubjectsRequest) String() string

type QuerySubjectsResponse 

type QuerySubjectsResponse struct {

	// subjects is the list of subjects.
	Subjects []*QuerySubjectsResponse_Subject `protobuf:"bytes,1,rep,name=subjects,proto3" json:"subjects,omitempty"`
	// pagination is the pagination of the response.
	Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QuerySubjectsResponse is the Query/Subjects response type.

func (*QuerySubjectsResponse) Descriptor deprecated 

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

Deprecated: Use QuerySubjectsResponse.ProtoReflect.Descriptor instead.

func (*QuerySubjectsResponse) GetPagination 

func (x *QuerySubjectsResponse) GetPagination() *v1beta1.PageResponse

func (*QuerySubjectsResponse) GetSubjects 

func (x *QuerySubjectsResponse) GetSubjects() []*QuerySubjectsResponse_Subject

func (*QuerySubjectsResponse) ProtoMessage 

func (*QuerySubjectsResponse) ProtoMessage()

func (*QuerySubjectsResponse) ProtoReflect 

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

func (*QuerySubjectsResponse) Reset 

func (x *QuerySubjectsResponse) Reset()

func (*QuerySubjectsResponse) String 

func (x *QuerySubjectsResponse) String() string

type QuerySubjectsResponse_Subject 

type QuerySubjectsResponse_Subject struct {

	// address is the address of the subject.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// steward is the address of the subject steward.
	Steward string `protobuf:"bytes,2,opt,name=steward,proto3" json:"steward,omitempty"`
	// metadata is the metadata of the subject.
	Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Subject is the subject properties.

func (*QuerySubjectsResponse_Subject) Descriptor deprecated 

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

Deprecated: Use QuerySubjectsResponse_Subject.ProtoReflect.Descriptor instead.

func (*QuerySubjectsResponse_Subject) GetAddress 

func (x *QuerySubjectsResponse_Subject) GetAddress() string

func (*QuerySubjectsResponse_Subject) GetMetadata 

func (x *QuerySubjectsResponse_Subject) GetMetadata() string

func (*QuerySubjectsResponse_Subject) GetSteward 

func (x *QuerySubjectsResponse_Subject) GetSteward() string

func (*QuerySubjectsResponse_Subject) ProtoMessage 

func (*QuerySubjectsResponse_Subject) ProtoMessage()

func (*QuerySubjectsResponse_Subject) ProtoReflect 

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

func (*QuerySubjectsResponse_Subject) Reset 

func (x *QuerySubjectsResponse_Subject) Reset()

func (*QuerySubjectsResponse_Subject) String 

func (x *QuerySubjectsResponse_Subject) String() string

type StateStore 

type StateStore interface {
	SubjectTable() SubjectTable
	SubjectSequenceTable() SubjectSequenceTable
	// contains filtered or unexported methods
}

func NewStateStore 

func NewStateStore(db ormtable.Schema) (StateStore, error)

type Subject 

type Subject struct {

	// address is the address of the subject.
	Address []byte `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// steward is the address of the subject steward.
	Steward []byte `protobuf:"bytes,2,opt,name=steward,proto3" json:"steward,omitempty"`
	// metadata is the metadata of the subject.
	Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Subject defines the table and properties of the subject.

func (*Subject) Descriptor deprecated 

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

Deprecated: Use Subject.ProtoReflect.Descriptor instead.

func (*Subject) GetAddress 

func (x *Subject) GetAddress() []byte

func (*Subject) GetMetadata 

func (x *Subject) GetMetadata() string

func (*Subject) GetSteward 

func (x *Subject) GetSteward() []byte

func (*Subject) ProtoMessage 

func (*Subject) ProtoMessage()

func (*Subject) ProtoReflect 

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

func (*Subject) Reset 

func (x *Subject) Reset()

func (*Subject) String 

func (x *Subject) String() string

type SubjectAddressIndexKey 

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

func (SubjectAddressIndexKey) WithAddress 

func (this SubjectAddressIndexKey) WithAddress(address []byte) SubjectAddressIndexKey

type SubjectIndexKey 

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

type SubjectIterator 

type SubjectIterator struct {
	ormtable.Iterator
}

func (SubjectIterator) Value 

func (i SubjectIterator) Value() (*Subject, error)

type SubjectPrimaryKey 

type SubjectPrimaryKey = SubjectAddressIndexKey

primary key starting index..

type SubjectSequence 

type SubjectSequence struct {

	// sequence is the sequence of the subject. The sequence is used to generate
	// subject accounts managed by the subject module.
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

SubjectSequence defines the table and properties of the subject sequence.

func (*SubjectSequence) Descriptor deprecated 

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

Deprecated: Use SubjectSequence.ProtoReflect.Descriptor instead.

func (*SubjectSequence) GetSequence 

func (x *SubjectSequence) GetSequence() uint64

func (*SubjectSequence) ProtoMessage 

func (*SubjectSequence) ProtoMessage()

func (*SubjectSequence) ProtoReflect 

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

func (*SubjectSequence) Reset 

func (x *SubjectSequence) Reset()

func (*SubjectSequence) String 

func (x *SubjectSequence) String() string

type SubjectSequenceTable 

type SubjectSequenceTable interface {
	Get(ctx context.Context) (*SubjectSequence, error)
	Save(ctx context.Context, subjectSequence *SubjectSequence) error
}

singleton store

func NewSubjectSequenceTable 

func NewSubjectSequenceTable(db ormtable.Schema) (SubjectSequenceTable, error)

type SubjectStewardIndexKey 

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

func (SubjectStewardIndexKey) WithSteward 

func (this SubjectStewardIndexKey) WithSteward(steward []byte) SubjectStewardIndexKey

type SubjectTable 

type SubjectTable interface {
	Insert(ctx context.Context, subject *Subject) error
	Update(ctx context.Context, subject *Subject) error
	Save(ctx context.Context, subject *Subject) error
	Delete(ctx context.Context, subject *Subject) error
	Has(ctx context.Context, address []byte) (found bool, err error)
	// Get returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
	Get(ctx context.Context, address []byte) (*Subject, error)
	List(ctx context.Context, prefixKey SubjectIndexKey, opts ...ormlist.Option) (SubjectIterator, error)
	ListRange(ctx context.Context, from, to SubjectIndexKey, opts ...ormlist.Option) (SubjectIterator, error)
	DeleteBy(ctx context.Context, prefixKey SubjectIndexKey) error
	DeleteRange(ctx context.Context, from, to SubjectIndexKey) error
	// contains filtered or unexported methods
}

func NewSubjectTable 

func NewSubjectTable(db ormtable.Schema) (SubjectTable, error)

type UnimplementedMsgServer 

type UnimplementedMsgServer struct{}

UnimplementedMsgServer 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 (UnimplementedMsgServer) CreateSubject 

func (UnimplementedMsgServer) CreateSubject(context.Context, *MsgCreateSubject) (*MsgCreateSubjectResponse, error)

func (UnimplementedMsgServer) RemoveSubject 

func (UnimplementedMsgServer) RemoveSubject(context.Context, *MsgRemoveSubject) (*MsgRemoveSubjectResponse, error)

func (UnimplementedMsgServer) UpdateSubjectMetadata 

func (UnimplementedMsgServer) UpdateSubjectMetadata(context.Context, *MsgUpdateSubjectMetadata) (*MsgUpdateSubjectMetadataResponse, error)

func (UnimplementedMsgServer) UpdateSubjectSteward 

func (UnimplementedMsgServer) UpdateSubjectSteward(context.Context, *MsgUpdateSubjectSteward) (*MsgUpdateSubjectStewardResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct{}

UnimplementedQueryServer 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 (UnimplementedQueryServer) Subject 

func (UnimplementedQueryServer) Subject(context.Context, *QuerySubjectRequest) (*QuerySubjectResponse, error)

func (UnimplementedQueryServer) Subjects 

func (UnimplementedQueryServer) Subjects(context.Context, *QuerySubjectsRequest) (*QuerySubjectsResponse, error)

func (UnimplementedQueryServer) SubjectsBySteward 

func (UnimplementedQueryServer) SubjectsBySteward(context.Context, *QuerySubjectsByStewardRequest) (*QuerySubjectsByStewardResponse, error)

type UnsafeMsgServer 

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

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

type UnsafeQueryServer 

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

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

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.