diff --git a/configspec/configapi.pb.go b/configspec/configapi.pb.go index ea45864..efb1e9d 100644 --- a/configspec/configapi.pb.go +++ b/configspec/configapi.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.30.0 -// protoc v4.23.2 +// protoc-gen-go v1.34.2 +// protoc v5.27.2 // source: github.com/dogmatiq/interopspec/configspec/configapi.proto package configspec @@ -308,6 +308,8 @@ type Handler struct { // The keys are the fully-qualified names of the message's Go type and the // value is the role that message plays within the application. ConsumedMessages map[string]MessageRole `protobuf:"bytes,5,rep,name=consumed_messages,json=consumedMessages,proto3" json:"consumed_messages,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3,enum=dogma.interop.v1.config.MessageRole"` + // IsDisabled indicates whether the handler is disabled. + IsDisabled bool `protobuf:"varint,6,opt,name=is_disabled,json=isDisabled,proto3" json:"is_disabled,omitempty"` } func (x *Handler) Reset() { @@ -377,6 +379,13 @@ func (x *Handler) GetConsumedMessages() map[string]MessageRole { return nil } +func (x *Handler) GetIsDisabled() bool { + if x != nil { + return x.IsDisabled + } + return false +} + // Identity represents the identity of an application or handler. type Identity struct { state protoimpl.MessageState @@ -461,7 +470,7 @@ var file_github_com_dogmatiq_interopspec_configspec_configapi_proto_rawDesc = [] 0x0a, 0x08, 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x72, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x64, 0x6f, 0x67, 0x6d, 0x61, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6f, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x48, 0x61, 0x6e, 0x64, 0x6c, - 0x65, 0x72, 0x52, 0x08, 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x72, 0x73, 0x22, 0xbb, 0x04, 0x0a, + 0x65, 0x72, 0x52, 0x08, 0x68, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x72, 0x73, 0x22, 0xdc, 0x04, 0x0a, 0x07, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x72, 0x12, 0x3d, 0x0a, 0x08, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x64, 0x6f, 0x67, 0x6d, 0x61, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6f, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x63, 0x6f, @@ -484,46 +493,48 @@ var file_github_com_dogmatiq_interopspec_configspec_configapi_proto_rawDesc = [] 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x72, 0x2e, 0x43, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x64, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x10, 0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x64, 0x4d, 0x65, 0x73, 0x73, - 0x61, 0x67, 0x65, 0x73, 0x1a, 0x69, 0x0a, 0x15, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x65, 0x64, - 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, - 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, - 0x3a, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x24, - 0x2e, 0x64, 0x6f, 0x67, 0x6d, 0x61, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6f, 0x70, 0x2e, 0x76, - 0x31, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, - 0x52, 0x6f, 0x6c, 0x65, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, - 0x69, 0x0a, 0x15, 0x43, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x64, 0x4d, 0x65, 0x73, 0x73, 0x61, - 0x67, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, - 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x3a, 0x0a, 0x05, 0x76, 0x61, - 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x24, 0x2e, 0x64, 0x6f, 0x67, 0x6d, - 0x61, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6f, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x63, 0x6f, 0x6e, - 0x66, 0x69, 0x67, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x6f, 0x6c, 0x65, 0x52, - 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x30, 0x0a, 0x08, 0x49, 0x64, - 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, - 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x2a, 0x4c, 0x0a, 0x0b, - 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x6f, 0x6c, 0x65, 0x12, 0x18, 0x0a, 0x14, 0x55, - 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x5f, 0x4d, 0x45, 0x53, 0x53, 0x41, 0x47, 0x45, 0x5f, 0x52, - 0x4f, 0x4c, 0x45, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07, 0x43, 0x4f, 0x4d, 0x4d, 0x41, 0x4e, 0x44, - 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x10, 0x02, 0x12, 0x0b, 0x0a, - 0x07, 0x54, 0x49, 0x4d, 0x45, 0x4f, 0x55, 0x54, 0x10, 0x03, 0x2a, 0x64, 0x0a, 0x0b, 0x48, 0x61, - 0x6e, 0x64, 0x6c, 0x65, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x18, 0x0a, 0x14, 0x55, 0x4e, 0x4b, - 0x4e, 0x4f, 0x57, 0x4e, 0x5f, 0x48, 0x41, 0x4e, 0x44, 0x4c, 0x45, 0x52, 0x5f, 0x54, 0x59, 0x50, - 0x45, 0x10, 0x00, 0x12, 0x0d, 0x0a, 0x09, 0x41, 0x47, 0x47, 0x52, 0x45, 0x47, 0x41, 0x54, 0x45, - 0x10, 0x01, 0x12, 0x0b, 0x0a, 0x07, 0x50, 0x52, 0x4f, 0x43, 0x45, 0x53, 0x53, 0x10, 0x02, 0x12, - 0x0f, 0x0a, 0x0b, 0x49, 0x4e, 0x54, 0x45, 0x47, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x10, 0x03, - 0x12, 0x0e, 0x0a, 0x0a, 0x50, 0x52, 0x4f, 0x4a, 0x45, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x10, 0x04, - 0x32, 0x84, 0x01, 0x0a, 0x09, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x41, 0x50, 0x49, 0x12, 0x77, - 0x0a, 0x10, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, - 0x6e, 0x73, 0x12, 0x30, 0x2e, 0x64, 0x6f, 0x67, 0x6d, 0x61, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, - 0x6f, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x4c, 0x69, 0x73, - 0x74, 0x41, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x1a, 0x31, 0x2e, 0x64, 0x6f, 0x67, 0x6d, 0x61, 0x2e, 0x69, 0x6e, 0x74, - 0x65, 0x72, 0x6f, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x4c, - 0x69, 0x73, 0x74, 0x41, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, - 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x2c, 0x5a, 0x2a, 0x67, 0x69, 0x74, 0x68, 0x75, - 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x64, 0x6f, 0x67, 0x6d, 0x61, 0x74, 0x69, 0x71, 0x2f, 0x69, - 0x6e, 0x74, 0x65, 0x72, 0x6f, 0x70, 0x73, 0x70, 0x65, 0x63, 0x2f, 0x63, 0x6f, 0x6e, 0x66, 0x69, - 0x67, 0x73, 0x70, 0x65, 0x63, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x61, 0x67, 0x65, 0x73, 0x12, 0x1f, 0x0a, 0x0b, 0x69, 0x73, 0x5f, 0x64, 0x69, 0x73, 0x61, 0x62, + 0x6c, 0x65, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0a, 0x69, 0x73, 0x44, 0x69, 0x73, + 0x61, 0x62, 0x6c, 0x65, 0x64, 0x1a, 0x69, 0x0a, 0x15, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x65, + 0x64, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, + 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, + 0x12, 0x3a, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, + 0x24, 0x2e, 0x64, 0x6f, 0x67, 0x6d, 0x61, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6f, 0x70, 0x2e, + 0x76, 0x31, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, + 0x65, 0x52, 0x6f, 0x6c, 0x65, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, + 0x1a, 0x69, 0x0a, 0x15, 0x43, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x64, 0x4d, 0x65, 0x73, 0x73, + 0x61, 0x67, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x3a, 0x0a, 0x05, 0x76, + 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x24, 0x2e, 0x64, 0x6f, 0x67, + 0x6d, 0x61, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6f, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x63, 0x6f, + 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x6f, 0x6c, 0x65, + 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x30, 0x0a, 0x08, 0x49, + 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6b, + 0x65, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x2a, 0x4c, 0x0a, + 0x0b, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x6f, 0x6c, 0x65, 0x12, 0x18, 0x0a, 0x14, + 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x5f, 0x4d, 0x45, 0x53, 0x53, 0x41, 0x47, 0x45, 0x5f, + 0x52, 0x4f, 0x4c, 0x45, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07, 0x43, 0x4f, 0x4d, 0x4d, 0x41, 0x4e, + 0x44, 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x10, 0x02, 0x12, 0x0b, + 0x0a, 0x07, 0x54, 0x49, 0x4d, 0x45, 0x4f, 0x55, 0x54, 0x10, 0x03, 0x2a, 0x64, 0x0a, 0x0b, 0x48, + 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x72, 0x54, 0x79, 0x70, 0x65, 0x12, 0x18, 0x0a, 0x14, 0x55, 0x4e, + 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x5f, 0x48, 0x41, 0x4e, 0x44, 0x4c, 0x45, 0x52, 0x5f, 0x54, 0x59, + 0x50, 0x45, 0x10, 0x00, 0x12, 0x0d, 0x0a, 0x09, 0x41, 0x47, 0x47, 0x52, 0x45, 0x47, 0x41, 0x54, + 0x45, 0x10, 0x01, 0x12, 0x0b, 0x0a, 0x07, 0x50, 0x52, 0x4f, 0x43, 0x45, 0x53, 0x53, 0x10, 0x02, + 0x12, 0x0f, 0x0a, 0x0b, 0x49, 0x4e, 0x54, 0x45, 0x47, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x10, + 0x03, 0x12, 0x0e, 0x0a, 0x0a, 0x50, 0x52, 0x4f, 0x4a, 0x45, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x10, + 0x04, 0x32, 0x84, 0x01, 0x0a, 0x09, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x41, 0x50, 0x49, 0x12, + 0x77, 0x0a, 0x10, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, + 0x6f, 0x6e, 0x73, 0x12, 0x30, 0x2e, 0x64, 0x6f, 0x67, 0x6d, 0x61, 0x2e, 0x69, 0x6e, 0x74, 0x65, + 0x72, 0x6f, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x4c, 0x69, + 0x73, 0x74, 0x41, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x31, 0x2e, 0x64, 0x6f, 0x67, 0x6d, 0x61, 0x2e, 0x69, 0x6e, + 0x74, 0x65, 0x72, 0x6f, 0x70, 0x2e, 0x76, 0x31, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, + 0x4c, 0x69, 0x73, 0x74, 0x41, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x2c, 0x5a, 0x2a, 0x67, 0x69, 0x74, 0x68, + 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x64, 0x6f, 0x67, 0x6d, 0x61, 0x74, 0x69, 0x71, 0x2f, + 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6f, 0x70, 0x73, 0x70, 0x65, 0x63, 0x2f, 0x63, 0x6f, 0x6e, 0x66, + 0x69, 0x67, 0x73, 0x70, 0x65, 0x63, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -540,7 +551,7 @@ func file_github_com_dogmatiq_interopspec_configspec_configapi_proto_rawDescGZIP var file_github_com_dogmatiq_interopspec_configspec_configapi_proto_enumTypes = make([]protoimpl.EnumInfo, 2) var file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes = make([]protoimpl.MessageInfo, 7) -var file_github_com_dogmatiq_interopspec_configspec_configapi_proto_goTypes = []interface{}{ +var file_github_com_dogmatiq_interopspec_configspec_configapi_proto_goTypes = []any{ (MessageRole)(0), // 0: dogma.interop.v1.config.MessageRole (HandlerType)(0), // 1: dogma.interop.v1.config.HandlerType (*ListApplicationsRequest)(nil), // 2: dogma.interop.v1.config.ListApplicationsRequest @@ -576,7 +587,7 @@ func file_github_com_dogmatiq_interopspec_configspec_configapi_proto_init() { return } if !protoimpl.UnsafeEnabled { - file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*ListApplicationsRequest); i { case 0: return &v.state @@ -588,7 +599,7 @@ func file_github_com_dogmatiq_interopspec_configspec_configapi_proto_init() { return nil } } - file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes[1].Exporter = func(v any, i int) any { switch v := v.(*ListApplicationsResponse); i { case 0: return &v.state @@ -600,7 +611,7 @@ func file_github_com_dogmatiq_interopspec_configspec_configapi_proto_init() { return nil } } - file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes[2].Exporter = func(v any, i int) any { switch v := v.(*Application); i { case 0: return &v.state @@ -612,7 +623,7 @@ func file_github_com_dogmatiq_interopspec_configspec_configapi_proto_init() { return nil } } - file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes[3].Exporter = func(v any, i int) any { switch v := v.(*Handler); i { case 0: return &v.state @@ -624,7 +635,7 @@ func file_github_com_dogmatiq_interopspec_configspec_configapi_proto_init() { return nil } } - file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_configspec_configapi_proto_msgTypes[4].Exporter = func(v any, i int) any { switch v := v.(*Identity); i { case 0: return &v.state diff --git a/configspec/configapi.proto b/configspec/configapi.proto index 89823b7..1c3c46f 100644 --- a/configspec/configapi.proto +++ b/configspec/configapi.proto @@ -71,6 +71,9 @@ message Handler { // The keys are the fully-qualified names of the message's Go type and the // value is the role that message plays within the application. map consumed_messages = 5; + + // IsDisabled indicates whether the handler is disabled. + bool is_disabled = 6; } // Identity represents the identity of an application or handler. diff --git a/configspec/configapi_grpc.pb.go b/configspec/configapi_grpc.pb.go index 2006cf2..2b9c4de 100644 --- a/configspec/configapi_grpc.pb.go +++ b/configspec/configapi_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 -// - protoc v4.23.2 +// - protoc-gen-go-grpc v1.4.0 +// - protoc v5.27.2 // source: github.com/dogmatiq/interopspec/configspec/configapi.proto package configspec @@ -15,8 +15,8 @@ import ( // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. -// Requires gRPC-Go v1.32.0 or later. -const _ = grpc.SupportPackageIsVersion7 +// Requires gRPC-Go v1.62.0 or later. +const _ = grpc.SupportPackageIsVersion8 const ( ConfigAPI_ListApplications_FullMethodName = "/dogma.interop.v1.config.ConfigAPI/ListApplications" @@ -25,6 +25,9 @@ const ( // ConfigAPIClient is the client API for ConfigAPI 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. +// +// ConfigAPI is a service for inspecting the configuration of Dogma applications +// hosted by the engine on the server. type ConfigAPIClient interface { // ListApplications returns the full configuration of all applications. ListApplications(ctx context.Context, in *ListApplicationsRequest, opts ...grpc.CallOption) (*ListApplicationsResponse, error) @@ -39,8 +42,9 @@ func NewConfigAPIClient(cc grpc.ClientConnInterface) ConfigAPIClient { } func (c *configAPIClient) ListApplications(ctx context.Context, in *ListApplicationsRequest, opts ...grpc.CallOption) (*ListApplicationsResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ListApplicationsResponse) - err := c.cc.Invoke(ctx, ConfigAPI_ListApplications_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ConfigAPI_ListApplications_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -50,6 +54,9 @@ func (c *configAPIClient) ListApplications(ctx context.Context, in *ListApplicat // ConfigAPIServer is the server API for ConfigAPI service. // All implementations should embed UnimplementedConfigAPIServer // for forward compatibility +// +// ConfigAPI is a service for inspecting the configuration of Dogma applications +// hosted by the engine on the server. type ConfigAPIServer interface { // ListApplications returns the full configuration of all applications. ListApplications(context.Context, *ListApplicationsRequest) (*ListApplicationsResponse, error) diff --git a/discoverspec/discoverapi.pb.go b/discoverspec/discoverapi.pb.go index 83ec999..21ac354 100644 --- a/discoverspec/discoverapi.pb.go +++ b/discoverspec/discoverapi.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.30.0 -// protoc v4.23.2 +// protoc-gen-go v1.34.2 +// protoc v5.27.2 // source: github.com/dogmatiq/interopspec/discoverspec/discoverapi.proto package discoverspec @@ -241,7 +241,7 @@ func file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_rawDesc } var file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_msgTypes = make([]protoimpl.MessageInfo, 3) -var file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_goTypes = []interface{}{ +var file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_goTypes = []any{ (*WatchApplicationsRequest)(nil), // 0: dogma.interop.v1.discover.WatchApplicationsRequest (*WatchApplicationsResponse)(nil), // 1: dogma.interop.v1.discover.WatchApplicationsResponse (*Identity)(nil), // 2: dogma.interop.v1.discover.Identity @@ -264,7 +264,7 @@ func file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_init() return } if !protoimpl.UnsafeEnabled { - file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*WatchApplicationsRequest); i { case 0: return &v.state @@ -276,7 +276,7 @@ func file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_init() return nil } } - file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_msgTypes[1].Exporter = func(v any, i int) any { switch v := v.(*WatchApplicationsResponse); i { case 0: return &v.state @@ -288,7 +288,7 @@ func file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_init() return nil } } - file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_discoverspec_discoverapi_proto_msgTypes[2].Exporter = func(v any, i int) any { switch v := v.(*Identity); i { case 0: return &v.state diff --git a/discoverspec/discoverapi_grpc.pb.go b/discoverspec/discoverapi_grpc.pb.go index eb22c36..38d993a 100644 --- a/discoverspec/discoverapi_grpc.pb.go +++ b/discoverspec/discoverapi_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 -// - protoc v4.23.2 +// - protoc-gen-go-grpc v1.4.0 +// - protoc v5.27.2 // source: github.com/dogmatiq/interopspec/discoverspec/discoverapi.proto package discoverspec @@ -15,8 +15,8 @@ import ( // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. -// Requires gRPC-Go v1.32.0 or later. -const _ = grpc.SupportPackageIsVersion7 +// Requires gRPC-Go v1.62.0 or later. +const _ = grpc.SupportPackageIsVersion8 const ( DiscoverAPI_WatchApplications_FullMethodName = "/dogma.interop.v1.discover.DiscoverAPI/WatchApplications" @@ -25,6 +25,8 @@ const ( // DiscoverAPIClient is the client API for DiscoverAPI 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. +// +// DiscoverAPI is a service for discovering the applications hosted on a server. type DiscoverAPIClient interface { // WatchApplications starts watching the server for updates to the // availability of Dogma applications. @@ -45,11 +47,12 @@ func NewDiscoverAPIClient(cc grpc.ClientConnInterface) DiscoverAPIClient { } func (c *discoverAPIClient) WatchApplications(ctx context.Context, in *WatchApplicationsRequest, opts ...grpc.CallOption) (DiscoverAPI_WatchApplicationsClient, error) { - stream, err := c.cc.NewStream(ctx, &DiscoverAPI_ServiceDesc.Streams[0], DiscoverAPI_WatchApplications_FullMethodName, opts...) + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &DiscoverAPI_ServiceDesc.Streams[0], DiscoverAPI_WatchApplications_FullMethodName, cOpts...) if err != nil { return nil, err } - x := &discoverAPIWatchApplicationsClient{stream} + x := &discoverAPIWatchApplicationsClient{ClientStream: stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -79,6 +82,8 @@ func (x *discoverAPIWatchApplicationsClient) Recv() (*WatchApplicationsResponse, // DiscoverAPIServer is the server API for DiscoverAPI service. // All implementations should embed UnimplementedDiscoverAPIServer // for forward compatibility +// +// DiscoverAPI is a service for discovering the applications hosted on a server. type DiscoverAPIServer interface { // WatchApplications starts watching the server for updates to the // availability of Dogma applications. @@ -114,7 +119,7 @@ func _DiscoverAPI_WatchApplications_Handler(srv interface{}, stream grpc.ServerS if err := stream.RecvMsg(m); err != nil { return err } - return srv.(DiscoverAPIServer).WatchApplications(m, &discoverAPIWatchApplicationsServer{stream}) + return srv.(DiscoverAPIServer).WatchApplications(m, &discoverAPIWatchApplicationsServer{ServerStream: stream}) } type DiscoverAPI_WatchApplicationsServer interface { diff --git a/envelopespec/envelope.pb.go b/envelopespec/envelope.pb.go index 7ad0e23..f9108a6 100644 --- a/envelopespec/envelope.pb.go +++ b/envelopespec/envelope.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.30.0 -// protoc v4.23.2 +// protoc-gen-go v1.34.2 +// protoc v5.27.2 // source: github.com/dogmatiq/interopspec/envelopespec/envelope.proto package envelopespec @@ -328,7 +328,7 @@ func file_github_com_dogmatiq_interopspec_envelopespec_envelope_proto_rawDescGZI } var file_github_com_dogmatiq_interopspec_envelopespec_envelope_proto_msgTypes = make([]protoimpl.MessageInfo, 2) -var file_github_com_dogmatiq_interopspec_envelopespec_envelope_proto_goTypes = []interface{}{ +var file_github_com_dogmatiq_interopspec_envelopespec_envelope_proto_goTypes = []any{ (*Envelope)(nil), // 0: dogma.interop.v1.envelope.Envelope (*Identity)(nil), // 1: dogma.interop.v1.envelope.Identity } @@ -349,7 +349,7 @@ func file_github_com_dogmatiq_interopspec_envelopespec_envelope_proto_init() { return } if !protoimpl.UnsafeEnabled { - file_github_com_dogmatiq_interopspec_envelopespec_envelope_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_envelopespec_envelope_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*Envelope); i { case 0: return &v.state @@ -361,7 +361,7 @@ func file_github_com_dogmatiq_interopspec_envelopespec_envelope_proto_init() { return nil } } - file_github_com_dogmatiq_interopspec_envelopespec_envelope_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_envelopespec_envelope_proto_msgTypes[1].Exporter = func(v any, i int) any { switch v := v.(*Identity); i { case 0: return &v.state diff --git a/eventstreamspec/streamapi.pb.go b/eventstreamspec/streamapi.pb.go index d8dedb9..aa45593 100644 --- a/eventstreamspec/streamapi.pb.go +++ b/eventstreamspec/streamapi.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.30.0 -// protoc v4.23.2 +// protoc-gen-go v1.34.2 +// protoc v5.27.2 // source: github.com/dogmatiq/interopspec/eventstreamspec/streamapi.proto package eventstreamspec @@ -613,7 +613,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_rawDes } var file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes = make([]protoimpl.MessageInfo, 9) -var file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_goTypes = []interface{}{ +var file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_goTypes = []any{ (*ConsumeRequest)(nil), // 0: dogma.interop.v1.eventstream.ConsumeRequest (*ConsumeResponse)(nil), // 1: dogma.interop.v1.eventstream.ConsumeResponse (*EventTypesRequest)(nil), // 2: dogma.interop.v1.eventstream.EventTypesRequest @@ -646,7 +646,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_init() return } if !protoimpl.UnsafeEnabled { - file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*ConsumeRequest); i { case 0: return &v.state @@ -658,7 +658,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_init() return nil } } - file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[1].Exporter = func(v any, i int) any { switch v := v.(*ConsumeResponse); i { case 0: return &v.state @@ -670,7 +670,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_init() return nil } } - file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[2].Exporter = func(v any, i int) any { switch v := v.(*EventTypesRequest); i { case 0: return &v.state @@ -682,7 +682,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_init() return nil } } - file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[3].Exporter = func(v any, i int) any { switch v := v.(*EventTypesResponse); i { case 0: return &v.state @@ -694,7 +694,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_init() return nil } } - file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[4].Exporter = func(v any, i int) any { switch v := v.(*EventType); i { case 0: return &v.state @@ -706,7 +706,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_init() return nil } } - file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[5].Exporter = func(v any, i int) any { switch v := v.(*UnrecognizedApplication); i { case 0: return &v.state @@ -718,7 +718,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_init() return nil } } - file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[6].Exporter = func(v any, i int) any { switch v := v.(*UnrecognizedEventType); i { case 0: return &v.state @@ -730,7 +730,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_init() return nil } } - file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[7].Exporter = func(v any, i int) any { switch v := v.(*NoRecognizedMediaTypes); i { case 0: return &v.state @@ -742,7 +742,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_init() return nil } } - file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[8].Exporter = func(v any, i int) any { switch v := v.(*UnsupportedStartPoint); i { case 0: return &v.state @@ -755,7 +755,7 @@ func file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_init() } } } - file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[0].OneofWrappers = []interface{}{ + file_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto_msgTypes[0].OneofWrappers = []any{ (*ConsumeRequest_Offset)(nil), } type x struct{} diff --git a/eventstreamspec/streamapi_grpc.pb.go b/eventstreamspec/streamapi_grpc.pb.go index 0413e6b..a31e270 100644 --- a/eventstreamspec/streamapi_grpc.pb.go +++ b/eventstreamspec/streamapi_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 -// - protoc v4.23.2 +// - protoc-gen-go-grpc v1.4.0 +// - protoc v5.27.2 // source: github.com/dogmatiq/interopspec/eventstreamspec/streamapi.proto package eventstreamspec @@ -15,8 +15,8 @@ import ( // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. -// Requires gRPC-Go v1.32.0 or later. -const _ = grpc.SupportPackageIsVersion7 +// Requires gRPC-Go v1.62.0 or later. +const _ = grpc.SupportPackageIsVersion8 const ( StreamAPI_Consume_FullMethodName = "/dogma.interop.v1.eventstream.StreamAPI/Consume" @@ -26,6 +26,9 @@ const ( // StreamAPIClient is the client API for StreamAPI 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. +// +// StreamAPI is a service for consuming offset-based ordered streams of event +// messages. type StreamAPIClient interface { // Consume starts consuming from a particular "start point" within an // application's event stream. @@ -72,11 +75,12 @@ func NewStreamAPIClient(cc grpc.ClientConnInterface) StreamAPIClient { } func (c *streamAPIClient) Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (StreamAPI_ConsumeClient, error) { - stream, err := c.cc.NewStream(ctx, &StreamAPI_ServiceDesc.Streams[0], StreamAPI_Consume_FullMethodName, opts...) + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &StreamAPI_ServiceDesc.Streams[0], StreamAPI_Consume_FullMethodName, cOpts...) if err != nil { return nil, err } - x := &streamAPIConsumeClient{stream} + x := &streamAPIConsumeClient{ClientStream: stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -104,8 +108,9 @@ func (x *streamAPIConsumeClient) Recv() (*ConsumeResponse, error) { } func (c *streamAPIClient) EventTypes(ctx context.Context, in *EventTypesRequest, opts ...grpc.CallOption) (*EventTypesResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(EventTypesResponse) - err := c.cc.Invoke(ctx, StreamAPI_EventTypes_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, StreamAPI_EventTypes_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -115,6 +120,9 @@ func (c *streamAPIClient) EventTypes(ctx context.Context, in *EventTypesRequest, // StreamAPIServer is the server API for StreamAPI service. // All implementations should embed UnimplementedStreamAPIServer // for forward compatibility +// +// StreamAPI is a service for consuming offset-based ordered streams of event +// messages. type StreamAPIServer interface { // Consume starts consuming from a particular "start point" within an // application's event stream. @@ -179,7 +187,7 @@ func _StreamAPI_Consume_Handler(srv interface{}, stream grpc.ServerStream) error if err := stream.RecvMsg(m); err != nil { return err } - return srv.(StreamAPIServer).Consume(m, &streamAPIConsumeServer{stream}) + return srv.(StreamAPIServer).Consume(m, &streamAPIConsumeServer{ServerStream: stream}) } type StreamAPI_ConsumeServer interface { diff --git a/wellknown/uuidpb/uuid.pb.go b/wellknown/uuidpb/uuid.pb.go index 83ee184..a97c145 100644 --- a/wellknown/uuidpb/uuid.pb.go +++ b/wellknown/uuidpb/uuid.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.30.0 -// protoc v4.23.2 +// protoc-gen-go v1.34.2 +// protoc v5.27.2 // source: github.com/dogmatiq/interopspec/wellknown/uuidpb/uuid.proto package uuidpb @@ -106,7 +106,7 @@ func file_github_com_dogmatiq_interopspec_wellknown_uuidpb_uuid_proto_rawDescGZI } var file_github_com_dogmatiq_interopspec_wellknown_uuidpb_uuid_proto_msgTypes = make([]protoimpl.MessageInfo, 1) -var file_github_com_dogmatiq_interopspec_wellknown_uuidpb_uuid_proto_goTypes = []interface{}{ +var file_github_com_dogmatiq_interopspec_wellknown_uuidpb_uuid_proto_goTypes = []any{ (*UUID)(nil), // 0: dogma.protobuf.UUID } var file_github_com_dogmatiq_interopspec_wellknown_uuidpb_uuid_proto_depIdxs = []int32{ @@ -123,7 +123,7 @@ func file_github_com_dogmatiq_interopspec_wellknown_uuidpb_uuid_proto_init() { return } if !protoimpl.UnsafeEnabled { - file_github_com_dogmatiq_interopspec_wellknown_uuidpb_uuid_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_github_com_dogmatiq_interopspec_wellknown_uuidpb_uuid_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*UUID); i { case 0: return &v.state